public class HdfsSink extends AbstractModuleFixture<HdfsSink>
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DEFAULT_DIRECTORY |
static java.lang.String |
DEFAULT_FILE_NAME |
label| Constructor and Description |
|---|
HdfsSink(java.lang.String directoryName,
java.lang.String fileName)
Initializes a hdfs file sink fixture;
|
| Modifier and Type | Method and Description |
|---|---|
HdfsSink |
directoryName(java.lang.String directoryName)
Sets the directory that the file will be written on hdfs
|
HdfsSink |
fileName(java.lang.String fileName)
Sets the file Name that the hdfs sink will write the data.
|
java.lang.String |
toDSL()
Renders the DSL for this fixture.
|
static HdfsSink |
withDefaults()
Returns an instance of the HdfsSink using defaults.
|
label, toStringpublic static final java.lang.String DEFAULT_FILE_NAME
public static final java.lang.String DEFAULT_DIRECTORY
public HdfsSink(java.lang.String directoryName,
java.lang.String fileName)
directoryName - The directory to write the file on the hdfs.fileName - The name of file to write on the hdfs.public static HdfsSink withDefaults()
public java.lang.String toDSL()
toDSL in class AbstractModuleFixture<HdfsSink>public HdfsSink fileName(java.lang.String fileName)
fileName - the name of the filepublic HdfsSink directoryName(java.lang.String directoryName)
directoryName - the name of the directory