Package com.helixframework.aws.dynamoscan

Class DynamoScanner

java.lang.Object

com.helixframework.aws.dynamoscan.DynamoScanner

public class DynamoScanner
extends Object

Scans a DynamoDB table in parallel.

Constructor Summary

Constructors

Constructor	Description
DynamoScanner(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDb, String tableName)	Creates a new instance of DynamoScanner.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<com.amazonaws.services.dynamodbv2.document.Item>	scan()	Executes the table scan.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DynamoScanner

public DynamoScanner(com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDynamoDb,
 String tableName)

Creates a new instance of DynamoScanner.

Parameters:

amazonDynamoDb - dynamodb client

tableName - name of table to scan

Method Details

scan

public reactor.core.publisher.Flux<com.amazonaws.services.dynamodbv2.document.Item> scan()

Executes the table scan.

Returns:

a Flux of Item