All Superinterfaces:

java.lang.AutoCloseable
```
public interface ReactiveStreamsIngestion
extends java.lang.AutoCloseable
```
The Reactive Streams Ingestion Library.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface ReactiveStreamsIngestion.Builder
The ReactiveStreamsIngestion library instance builder.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`static ReactiveStreamsIngestion.Builder`	`builder()`	Returns a new `RSIBuilder`.
`void`	`close()`	Initiates an orderly shutdown in which previously submitted records are ingested, but no new records will be accepted.
`static <T> PushPublisher<T>`	`pushPublisher()`	Returns a new `PushPublisher` of this `ReactiveStreamsIngestion`.
`<T> java.util.concurrent.Flow.Subscriber<T>`	`subscriber()`	Returns a new `Flow.Subscriber` of this `ReactiveStreamsIngestion`.

- Method Detail
  - builder
```
static ReactiveStreamsIngestion.Builder builder()
```
    Returns a new RSIBuilder.
    
    Returns:
    
    a new RSIBuilder. Not null.
  - pushPublisher
```
static <T> PushPublisher<T> pushPublisher()
```
    Returns a new PushPublisher of this ReactiveStreamsIngestion.
    
    Type Parameters:
    
    T - the type of the object published.
    
    Returns:
    
    the PushPublisher . Not null.
  - subscriber
```
<T> java.util.concurrent.Flow.Subscriber<T> subscriber()
```
    Returns a new Flow.Subscriber of this ReactiveStreamsIngestion. The publishing item can be a Datum[] or Object[] given that the order of column values in item match the pre-declared column names. The item can also be a byte[] or an object of class annotated with StreamField} or a Map of column name and value pairs. If an entry isn't supplied in the Map, RSI defaults the value of column to null. If the publishing item is a byte[], the library applies the supplied Function to transform byte[] in to a result. For records of sharded database, the publishing item can be either byte[] or ShardRecord.
    
    Type Parameters:
    
    T - The publishing item type.
    
    Returns:
    
    a Flow.Subscriber.
  - close
```
void close()
```
    Initiates an orderly shutdown in which previously submitted records are ingested, but no new records will be accepted. Invocation has no additional effect if already shut down. This method waits for previously submitted records to complete ingestion.
    
    Specified by:
    
    close in interface java.lang.AutoCloseable

Interface ReactiveStreamsIngestion

Nested Class Summary

Method Summary

Method Detail

builder

pushPublisher

subscriber

close