Modifier and Type | Class and Description |
---|---|
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
class |
LocalCollectionOutputFormat<T>
An output format that adds records to a collection.
|
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCsvOutputFormat<T extends scala.Product>
This is an OutputFormat to serialize Scala Tuples to text.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputFormatSinkFunction<IN>
Deprecated.
Please use the
BucketingSink for writing to files from a streaming program. |
Modifier and Type | Class and Description |
---|---|
class |
AvroKeyValueSinkWriter<K,V>
Implementation of AvroKeyValue writer that can be used in Sink.
|
class |
RollingSink<T>
Deprecated.
use
BucketingSink instead. |
class |
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
A
Writer that writes the bucket files as Hadoop SequenceFiles . |
Modifier and Type | Class and Description |
---|---|
class |
BucketingSink<T>
Sink that emits its input elements to
FileSystem files within
buckets. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.