Methods in org.apache.flume.sink.hdfs with parameters of type FlumeFormatter |
void |
HDFSWriter.append(Event e,
FlumeFormatter fmt)
|
void |
HDFSSequenceFile.append(Event e,
FlumeFormatter formatter)
|
void |
HDFSDataStream.append(Event e,
FlumeFormatter fmt)
|
void |
HDFSCompressedDataStream.append(Event e,
FlumeFormatter fmt)
|
void |
HDFSWriter.open(String filePath,
CompressionCodec codec,
CompressionType cType,
FlumeFormatter fmt)
|
void |
HDFSSequenceFile.open(String filePath,
CompressionCodec codeC,
CompressionType compType,
FlumeFormatter fmt)
|
void |
HDFSDataStream.open(String filePath,
CompressionCodec codec,
CompressionType cType,
FlumeFormatter fmt)
|
void |
HDFSCompressedDataStream.open(String filePath,
CompressionCodec codec,
CompressionType cType,
FlumeFormatter fmt)
|
void |
BucketWriter.open(String fPath,
CompressionCodec codec,
CompressionType cType,
HDFSWriter hWriter,
FlumeFormatter fmt)
|
void |
HDFSWriter.open(String filePath,
FlumeFormatter fmt)
|
void |
HDFSSequenceFile.open(String filePath,
FlumeFormatter fmt)
|
void |
HDFSDataStream.open(String filePath,
FlumeFormatter fmt)
|
void |
HDFSCompressedDataStream.open(String filePath,
FlumeFormatter fmt)
|
void |
BucketWriter.open(String fPath,
HDFSWriter hWriter,
FlumeFormatter fmt)
|