toggle menu
river
jvm
switch theme
connector-amqp
com.
river.
connector.
amqp
auto
Ack
Consume()
connection()
consume()
Message
Default
Simple
non
Blocking
Connection
Factory()
publish
Flow()
Receiving
Message
Auto
Ack
Manual
Ack
with
Channel()
connector-apache-kafka
com.
river.
connector.
apache.
kafka
acknowledge()
co
Commit()
kafka
Receiver()
kafka
Receiver
Flow()
kafka
Sender()
kafka
Sender
Channel()
Mutable
Receiver
Options
Subscription
Companion
Mutable
Sender
Options
Property
Builder
receive
As
Flow()
receiver
Options()
send()
sender
Options()
connector-aws-lambda
com.
river.
connector.
aws.
lambda
invoke
Flow()
connector-aws-s3
com.
river.
connector.
aws.
s3
download()
merge
Contents()
select
Object
Content()
upload()
upload
Bytes()
upload
Split()
upload
Split
Items()
com.
river.
connector.
aws.
s3.
model
S3Response
Complete
Multipart
Upload
Create
Multipart
Upload
Multipart
Response
Put
Object
Upload
Part
Upload
Part
Copy
connector-aws-ses
com.
river.
connector.
aws.
ses
send
Email
Flow()
com.
river.
connector.
aws.
ses.
model
Ses
Request
Bulk
Templated
Companion
Raw
Companion
Single
Companion
Single
Templated
Companion
Ses
Response
Bulk
Templated
Raw
Single
Single
Templated
connector-aws-sns
com.
river.
connector.
aws.
sns
publish
Flow()
connector-aws-sqs
com.
river.
connector.
aws.
sqs
acknowledge
With()
acknowledgment
Message
Flow()
change
Message
Visibility
Flow()
delete
Messages
Flow()
on
Message()
on
Messages()
receive
Messages
As
Flow()
send
Message
Flow()
com.
river.
connector.
aws.
sqs.
model
Acknowledgment
Change
Message
Visibility
Delete
Ignore
Change
Message
Visibility
Result
Commit
Configuration
Message
Acknowledgment
Message
Acknowledgment
Result
Message
Delete
Result
On
Error
Complete
Retry
Throw
Receive
Configuration
Send
Message
Result
Sqs
Queue
Companion
Sqs
Result
Failure
Success
connector-azure-queue-storage
com.
river.
connector.
azure.
queue.
storage
delete()
delete
Messages
Flow()
receive
Messages
As
Flow()
send
Messages
Flow()
com.
river.
connector.
azure.
queue.
storage.
model
Send
Message
Request
connector-console
com.
river.
connector.
console
console
In()
console
Out()
Out
Type
DEFAULT
ERROR
Print
BREAK_LINE
NO_BREAK
connector-elasticsearch
com.
river.
connector.
elasticsearch
Document
index
Flow()
max
Result
Window()
Paginated
Search
By
Search
After
Field
Default
paginated
Search
Flow()
to
Document()
connector-file
com.
river.
connector.
file
also
Append
To()
also
Write
To()
append
From()
append
To()
as
Flow()
as
Input
Stream()
async
Channel()
co
Read()
co
Write()
flow()
read
As
Flow()
read
File
As
Flow()
unzip
File()
write
Flow()
write
From()
write
To()
zip
File()
com.
river.
connector.
file.
model
Contentful
Zip
Entry
connector-format-csv
com.
river.
connector.
format.
csv
csv()
parse
Csv()
parse
Csv
With
Headers()
raw
Csv()
connector-format-json
com.
river.
connector.
format.
json
as
Json
Node()
as
Json
String()
as
Parsed
Json()
as
Value()
default
Object
Mapper
parse
Json
Array()
parse
Json
Lines()
connector-format-positional-flat-line
com.
river.
connector.
format.
positional.
flat.
line
Field
mapped
As()
parsed
To()
record()
Record
Builder
Record
Def
to
Positional
Flat
Line()
connector-ftp
com.
river.
connector.
ftp
connect()
download()
upload()
com.
river.
connector.
ftp.
model
Ftp
Configuration
Credentials
Secure
connector-github
com.
river.
connector.
github
commits
As
Flow()
download
Repository
Archive()
Github
Api
Companion
issues
As
Flow()
pull
Requests
As
Flow()
repositories
As
Flow()
tree
As
Flow()
com.
river.
connector.
github.
model
Blob
Content
Encoding
UTF-8
BASE64
Commit
Author
Commit
Author
Commit
Committer
Commit
Details
Committer
Compression
Type
ZIP
TAR
Content
Dir
File
File
Content
Issue
Label
User
Pull
Request
Branch
User
Query
Parameters
Repository
Owner
Tree
Ref
Tree
Entry
Blob
Tree
com.
river.
connector.
github.
model.
query
Commit
Query
Issue
Query
Direction
ASC
DESC
Filter
ASSIGNED
CREATED
MENTIONED
SUBSCRIBED
REPOS
ALL
Sort
CREATED
UPDATED
COMMENTS
State
OPEN
CLOSED
ALL
Pageable
Query
Pull
Request
Query
Direction
ASC
DESC
Sort
CREATED
UPDATED
POPULARITY
LONG_RUNNING
State
OPEN
CLOSED
ALL
Repository
Issue
Query
Direction
ASC
DESC
Sort
CREATED
UPDATED
COMMENTS
State
OPEN
CLOSED
ALL
Repository
Query
Direction
ASC
DESC
Sort
CREATED
UPDATED
PUSHED
FULL_NAME
Type
ALL
PUBLIC
PRIVATE
FORKS
SOURCES
MEMBER
connector-google-drive
com.
river.
connector.
google.
drive
download()
File
List
Files
List
Query
Google
Drive
Api
Companion
Google
Drive
File
list
Files()
connector-http
com.
river.
connector.
http
Authorization
Companion
body
As
Flow()
co
Send()
Custom
Http
Request
Builder
delete()
discarding
get()
head()
Http
Method
GET
POST
PUT
HEAD
DELETE
OPTIONS
PATCH
map()
of
Byte
Array
of
Byte
Array
Flow
of
Flow
of
Lines
of
Server
Sent
Event
Flow
of
String
of
String
Flow
options()
parse
As
Server
Sent
Events()
patch()
post()
put()
request()
send
And
Handle()
Server
Sent
Event
Companion
connector-jms
com.
river.
connector.
jms
consume()
send
To
Destination()
com.
river.
connector.
jms.
model
Committable
Message
Committable
Bytes
Message
Committable
Map
Message
Committable
Object
Message
Committable
Text
Message
Companion
Default
Message
Credentials
Delivery
Mode
NON_PERSISTENT
PERSISTENT
Jms
Consumer
Jms
Destination
Queue
Topic
Jms
Message
Bytes
Map
Object
Text
Jms
Primitive
Boolean
Bytes
Double
Float
Int
Long
Text
Session
Mode
SESSION_TRANSACTED
AUTO_ACKNOWLEDGE
CLIENT_ACKNOWLEDGE
DUPS_OK_ACKNOWLEDGE
connector-ktor-network
com.
river.
connector.
ktor.
network
await
Bytes()
await
Closed()
await
Line()
close()
flow
Of()
flow
Of
Byte
Array()
flow
Of
Bytes()
flow
Of
Lines()
flush()
is
Closed
For
Read
is
Closed
For
Write
is
Connection
Active
packet
Tcp
use()
while
Active()
write()
write
Line()
connector-mongodb
com.
river.
connector.
mongodb
find
As
Flow()
insert()
insert
Many()
replace()
update()
update
Many()
connector-rdbms-jdbc
com.
river.
connector.
rdbms.
jdbc
batch
Update()
Jdbc
Companion
query()
Row
single
Update()
typed
Query()
connector-rdbms-r2dbc
com.
river.
connector.
rdbms.
r2dbc
as
Rows()
batch
Update()
map
Row()
query()
Result
Row
rows
Updated()
single
Update()
com.
river.
connector.
rdbms.
r2dbc.
model
Returning
Default
Generated
Values
Companion
connector-red-hat-debezium
com.
river.
connector.
red.
hat.
debezium
debezium
Flow()
com.
river.
connector.
red.
hat.
debezium.
model
Committable
Offset
Committable
Record
connector-redis
com.
river.
connector.
redis
semaphore()
core
com.
river.
core
also
To()
as
Byte
Array()
as
Byte
Buffer()
as
Bytes()
as
String()
async
Async
Semaphore
Companion
catch
And
Emit
Last()
Channel
Receiver
Context
Companion
chunked()
collect
As
Receiver()
collect
Async()
collect
Catching()
collect
With
Timeout()
complete
All()
complete
All
With()
Concurrency
Info
Concurrency
Strategy
Companion
consume()
count
On
Window()
early
Complete
If()
Experimental
River
Api
flat
Map
Flow()
flat
Map
Iterable()
flat
Map
Iterable
Async()
flatten
As
Byte
Array()
flatten
Flow()
flatten
Iterable()
flow
Of
Suspend()
Group
Strategy
Count
Time
Window
indefinitely
Repeat()
intersperse()
join
To
String()
launch()
launch
Collect()
lazy
Async
lines()
map
Async()
Object
Pool
Object
Holder
object
Pool()
on
Each
Async()
plus()
poll()
poll
With
State()
promise
Flow()
River
Preview
split()
split
Every()
stoppable
Flow()
Stoppable
Flow
Collector
Companion
sum()
throttle()
Throttle
Strategy
Suspend
Drop
tick()
to
Channel()
to
List()
unbounded
Long
Flow()
unordered
Flat
Map
Iterable
Async()
unordered
Map
Async()
unordered
On
Each
Async()
with
Promise()
zip
Async()
connector-jms
/
com.river.connector.jms.model
/
JmsMessage
/
Object
/
Object
Object
constructor
(
value
:
Serializable
,
correlationId
:
String
?
=
null
,
replyTo
:
JmsDestination
?
=
null
,
deliveryMode
:
DeliveryMode
=
DeliveryMode.PERSISTENT
,
properties
:
Map
<
String
,
JmsPrimitive
<
*
>
>
=
emptyMap()
)