Modifier and Type | Interface and Description |
---|---|
interface |
KeyValueScheme |
interface |
MessageMetadataScheme |
Modifier and Type | Class and Description |
---|---|
class |
StringKeyValueScheme |
class |
StringMessageAndMetadataScheme |
class |
StringScheme |
Modifier and Type | Class and Description |
---|---|
class |
RawScheme |
Modifier and Type | Field and Description |
---|---|
Scheme |
SchemeAsMultiScheme.scheme |
Modifier and Type | Method and Description |
---|---|
Scheme |
ISchemableSpout.getScheme() |
Modifier and Type | Method and Description |
---|---|
void |
ISchemableSpout.setScheme(Scheme scheme) |
Constructor and Description |
---|
SchemeAsMultiScheme(Scheme scheme) |
Constructor and Description |
---|
TridentSocketSpout(Scheme scheme,
String host,
int port) |
Modifier and Type | Class and Description |
---|---|
class |
AvroScheme
AvroScheme uses generic(without code generation) instead of specific(with code generation) readers.
|
Modifier and Type | Class and Description |
---|---|
class |
CsvScheme
CsvScheme uses the standard RFC4180 CSV Parser One of the difference from Tsv format is that fields with embedded commas will be quoted.
|
Modifier and Type | Class and Description |
---|---|
class |
JsonScheme |
Modifier and Type | Class and Description |
---|---|
class |
TsvScheme
TsvScheme uses a simple delimited format implemention by splitting string, and it supports user defined delimiter.
|
Modifier and Type | Method and Description |
---|---|
static Scheme |
SerdeUtils.getScheme(String inputFormatClass,
Properties properties,
List<String> fieldNames) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.