JavaScript is disabled on your browser.
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
C
E
F
G
H
I
K
O
P
R
S
T
V
W
C
cleanUp()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
cleanUp()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
client
- Variable in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
client
- Variable in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
E
equals(Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
equals(Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
equals(Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
F
fromValue(String)
- Static method in enum org.apache.streams.amazon.kinesis.
KinesisConfiguration.Protocol
G
getAdditionalProperties()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
getAdditionalProperties()
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
getAdditionalProperties()
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
getId()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
getId()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
getKey()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Your Amazon Key (Required)
getProtocol()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Whether you are using HTTP or HTTPS
getRegion()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
The AWS region where your bucket resides
getSecretKey()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Your Amazon Secret Key (Required)
getStream()
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
getStreams()
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
H
hashCode()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
hashCode()
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
hashCode()
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
I
isRunning()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
K
KinesisConfiguration
- Class in
org.apache.streams.amazon.kinesis
KinesisConfiguration()
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisConfiguration
KinesisConfiguration.Protocol
- Enum in
org.apache.streams.amazon.kinesis
KinesisPersistReader
- Class in
org.apache.streams.amazon.kinesis
KinesisPersistReader()
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisPersistReader
KinesisPersistReader(KinesisReaderConfiguration)
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisPersistReader
KinesisPersistReaderTask
- Class in
org.apache.streams.amazon.kinesis
KinesisPersistReaderTask(KinesisPersistReader, String, String)
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisPersistReaderTask
KinesisPersistWriter
- Class in
org.apache.streams.amazon.kinesis
Created by sblackmon on 9/2/15.
KinesisPersistWriter()
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
KinesisPersistWriter(KinesisWriterConfiguration)
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
KinesisReaderConfiguration
- Class in
org.apache.streams.amazon.kinesis
KinesisReaderConfiguration()
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
KinesisWriterConfiguration
- Class in
org.apache.streams.amazon.kinesis
KinesisWriterConfiguration()
- Constructor for class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
O
org.apache.streams.amazon.kinesis
- package org.apache.streams.amazon.kinesis
P
persistQueue
- Variable in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
persistQueue
- Variable in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
pollInterval
- Variable in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
prepare(Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
prepare(Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
R
readAll()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
readCurrent()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
readNew(BigInteger)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
readRange(DateTime, DateTime)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
run()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReaderTask
S
setAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
setAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
setAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
setConfig(KinesisReaderConfiguration)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
setConfig(KinesisWriterConfiguration)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
setKey(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Your Amazon Key (Required)
setProtocol(KinesisConfiguration.Protocol)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Whether you are using HTTP or HTTPS
setRegion(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
The AWS region where your bucket resides
setSecretKey(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
Your Amazon Secret Key (Required)
setStream(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
setStreams(List<String>)
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
startStream()
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
STREAMS_ID
- Static variable in class org.apache.streams.amazon.kinesis.
KinesisPersistReader
STREAMS_ID
- Static variable in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
T
toString()
- Method in enum org.apache.streams.amazon.kinesis.
KinesisConfiguration.Protocol
toString()
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
toString()
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
toString()
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
V
valueOf(String)
- Static method in enum org.apache.streams.amazon.kinesis.
KinesisConfiguration.Protocol
Returns the enum constant of this type with the specified name.
values()
- Static method in enum org.apache.streams.amazon.kinesis.
KinesisConfiguration.Protocol
Returns an array containing the constants of this enum type, in the order they are declared.
W
withAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
withAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
withAdditionalProperty(String, Object)
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
withKey(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
withProtocol(KinesisConfiguration.Protocol)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
withRegion(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
withSecretKey(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisConfiguration
withStream(String)
- Method in class org.apache.streams.amazon.kinesis.
KinesisWriterConfiguration
withStreams(List<String>)
- Method in class org.apache.streams.amazon.kinesis.
KinesisReaderConfiguration
write(StreamsDatum)
- Method in class org.apache.streams.amazon.kinesis.
KinesisPersistWriter
C
E
F
G
H
I
K
O
P
R
S
T
V
W
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2012–2016
The Apache Software Foundation
. All rights reserved.