Uses of Interface
org.apache.storm.spout.Scheme

Packages that use Scheme

Package	Description
org.apache.storm.rocketmq
org.apache.storm.rocketmq.spout.scheme
org.apache.storm.spout
org.apache.storm.sql.kafka
org.apache.storm.sql.runtime.datasource.socket.spout
org.apache.storm.sql.runtime.serde.avro
org.apache.storm.sql.runtime.serde.csv
org.apache.storm.sql.runtime.serde.json
org.apache.storm.sql.runtime.serde.tsv
org.apache.storm.sql.runtime.utils

Uses of Scheme in org.apache.storm.rocketmq

Methods in org.apache.storm.rocketmq that return Scheme

Modifier and Type	Method and Description
static Scheme	RocketMqUtils.createScheme(Properties props) Create Scheme by Properties.

Methods in org.apache.storm.rocketmq with parameters of type Scheme

Modifier and Type	Method and Description
static List<Object>	RocketMqUtils.generateTuples(org.apache.rocketmq.common.message.Message msg, Scheme scheme) Generate Storm tuple values by Message and Scheme.

Uses of Scheme in org.apache.storm.rocketmq.spout.scheme

Subinterfaces of Scheme in org.apache.storm.rocketmq.spout.scheme

Modifier and Type	Interface and Description
interface	KeyValueScheme

Classes in org.apache.storm.rocketmq.spout.scheme that implement Scheme

Modifier and Type	Class and Description
class	StringKeyValueScheme
class	StringScheme

Uses of Scheme in org.apache.storm.spout

Classes in org.apache.storm.spout that implement Scheme

Modifier and Type	Class and Description
class	RawScheme

Fields in org.apache.storm.spout declared as Scheme

Modifier and Type	Field and Description
Scheme	SchemeAsMultiScheme.scheme

Methods in org.apache.storm.spout that return Scheme

Modifier and Type	Method and Description
Scheme	ISchemableSpout.getScheme()

Methods in org.apache.storm.spout with parameters of type Scheme

Modifier and Type	Method and Description
void	ISchemableSpout.setScheme(Scheme scheme)

Constructors in org.apache.storm.spout with parameters of type Scheme

Constructor and Description
SchemeAsMultiScheme(Scheme scheme)

Uses of Scheme in org.apache.storm.sql.kafka

Constructors in org.apache.storm.sql.kafka with parameters of type Scheme

Constructor and Description
RecordTranslatorSchemeAdapter(Scheme delegate)

Uses of Scheme in org.apache.storm.sql.runtime.datasource.socket.spout

Constructors in org.apache.storm.sql.runtime.datasource.socket.spout with parameters of type Scheme

Constructor and Description
SocketSpout(Scheme scheme, String host, int port) SocketSpout Constructor.

Uses of Scheme in org.apache.storm.sql.runtime.serde.avro

Classes in org.apache.storm.sql.runtime.serde.avro that implement Scheme

Modifier and Type	Class and Description
class	AvroScheme AvroScheme uses generic(without code generation) instead of specific(with code generation) readers.

Uses of Scheme in org.apache.storm.sql.runtime.serde.csv

Classes in org.apache.storm.sql.runtime.serde.csv that implement Scheme

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.

Uses of Scheme in org.apache.storm.sql.runtime.serde.json

Classes in org.apache.storm.sql.runtime.serde.json that implement Scheme

Modifier and Type	Class and Description
class	JsonScheme

Uses of Scheme in org.apache.storm.sql.runtime.serde.tsv

Classes in org.apache.storm.sql.runtime.serde.tsv that implement Scheme

Modifier and Type	Class and Description
class	TsvScheme TsvScheme uses a simple delimited format implemention by splitting string, and it supports user defined delimiter.

Uses of Scheme in org.apache.storm.sql.runtime.utils

Methods in org.apache.storm.sql.runtime.utils that return Scheme

Modifier and Type	Method and Description
static Scheme	SerdeUtils.getScheme(String inputFormatClass, Properties properties, List<String> fieldNames) Get a Scheme instance based on specific configurations.