HdfsBolt |
HdfsBolt.addRotationAction(RotationAction action) |
HdfsBolt |
HdfsBolt.withConfigKey(String configKey) |
HdfsBolt |
HdfsBolt.withFileNameFormat(FileNameFormat fileNameFormat) |
HdfsBolt |
HdfsBolt.withFsUrl(String fsUrl) |
HdfsBolt |
HdfsBolt.withMaxOpenFiles(int maxOpenFiles) |
HdfsBolt |
HdfsBolt.withPartitioner(Partitioner partitioner) |
HdfsBolt |
HdfsBolt.withRecordFormat(RecordFormat format) |
HdfsBolt |
HdfsBolt.withRetryCount(int fileRetryCount) |
HdfsBolt |
HdfsBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
HdfsBolt |
HdfsBolt.withSyncPolicy(SyncPolicy syncPolicy) |
HdfsBolt |
HdfsBolt.withTickTupleIntervalSeconds(int interval) |