Package | Description |
---|---|
com.mozilla.secops.input |
Pipeline input
|
Modifier and Type | Method and Description |
---|---|
InputElement |
InputElement.addFileInput(String input)
Add a new file input
|
InputElement |
InputElement.addKinesisInput(String input)
Add new Kinesis input
|
InputElement |
InputElement.addPubsubInput(String input)
Add new Pubsub input
|
InputElement |
InputElement.addWiredStream(org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<String>> s)
Add wired stream
|
static InputElement |
InputElement.fromPipelineOptions(String name,
InputOptions options,
String cfgTickMessage)
Return an
InputElement given pipeline options |
InputElement |
Input.getInputElementByName(String name)
Get an input element by name
|
InputElement |
InputElement.setConfigurationTicks(String cfgTickMessage,
Integer cfgTickInterval,
long cfgTickMax)
Set configuration ticks for input element
|
InputElement |
InputElement.setEventFilter(EventFilter filter)
Set event filter to use with parsed reads
|
InputElement |
InputElement.setParserConfiguration(ParserCfg parserCfg)
Set the parser configuration to use with parsed reads
|
Modifier and Type | Method and Description |
---|---|
ArrayList<InputElement> |
Input.getInputElements()
Get input elements
|
Modifier and Type | Method and Description |
---|---|
Input |
Input.withInputElement(InputElement el)
Add input element
|
Modifier and Type | Method and Description |
---|---|
void |
Input.setInputElements(ArrayList<InputElement> elements)
Set input elements
|
Copyright © 2022. All rights reserved.