B C E F O P R S T W
All Classes All Packages

B

baseUrl() - Method in class org.apache.beam.sdk.io.solr.SolrIO.ReplicaInfo

C

ConnectionConfiguration() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.ConnectionConfiguration

coreName() - Method in class org.apache.beam.sdk.io.solr.SolrIO.ReplicaInfo

coreUrl() - Method in class org.apache.beam.sdk.io.solr.SolrIO.ReplicaInfo

create(int, Duration) - Static method in class org.apache.beam.sdk.io.solr.SolrIO.RetryConfiguration

create(String) - Static method in class org.apache.beam.sdk.io.solr.SolrIO.ConnectionConfiguration

Creates a new Solr connection configuration.

E

expand(PBegin) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

expand(PCollection<SolrIO.Read>) - Method in class org.apache.beam.sdk.io.solr.SolrIO.ReadAll

expand(PCollection<SolrInputDocument>) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Write

F

from(String) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

Provide name of collection while reading from Solr.

O

org.apache.beam.sdk.io.solr - package org.apache.beam.sdk.io.solr

Transforms for reading and writing from/to Solr.

P

populateDisplayData(DisplayData.Builder) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

R

read() - Static method in class org.apache.beam.sdk.io.solr.SolrIO

Read() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.Read

readAll() - Static method in class org.apache.beam.sdk.io.solr.SolrIO

ReadAll() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.ReadAll

ReplicaInfo() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.ReplicaInfo

RetryConfiguration() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.RetryConfiguration

S

SolrIO - Class in org.apache.beam.sdk.io.solr

Transforms for reading and writing data from/to Solr.

SolrIO.ConnectionConfiguration - Class in org.apache.beam.sdk.io.solr

A POJO describing a connection configuration to Solr.

SolrIO.Read - Class in org.apache.beam.sdk.io.solr

A PTransform reading data from Solr.

SolrIO.ReadAll - Class in org.apache.beam.sdk.io.solr

SolrIO.ReplicaInfo - Class in org.apache.beam.sdk.io.solr

A POJO describing a replica of Solr.

SolrIO.RetryConfiguration - Class in org.apache.beam.sdk.io.solr

A POJO encapsulating a configuration for retry behavior when issuing requests to Solr.

SolrIO.Write - Class in org.apache.beam.sdk.io.solr

A PTransform writing data to Solr.

T

to(String) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Write

Provide name of collection while reading from Solr.

W

withBasicCredentials(String, String) - Method in class org.apache.beam.sdk.io.solr.SolrIO.ConnectionConfiguration

If Solr basic authentication is enabled, provide the username and password.

withConnectionConfiguration(SolrIO.ConnectionConfiguration) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

Provide the Solr connection configuration object.

withConnectionConfiguration(SolrIO.ConnectionConfiguration) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Write

Provide the Solr connection configuration object.

withMaxBatchSize(int) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Write

Provide a maximum size in number of documents for the batch.

withQuery(String) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

Provide a query used while reading from Solr.

withReplicaInfo(SolrIO.ReplicaInfo) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Read

Read from a specific Replica (partition).

withRetryConfiguration(SolrIO.RetryConfiguration) - Method in class org.apache.beam.sdk.io.solr.SolrIO.Write

Provides configuration to retry a failed batch call to Solr.

write() - Static method in class org.apache.beam.sdk.io.solr.SolrIO

Write() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.Write

B C E F O P R S T W
All Classes All Packages