BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/emr/src/main/java/com/amazon/aws/blog/function/PreFetcherFlatMapFunction.java [64:81]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        final DescribeReplicationGroupsResult describeReplicationGroupsResult =
                elastiCache.describeReplicationGroups(describeReplicationGroupsRequest);

        System.out.println("found num groups: " + describeReplicationGroupsResult.getReplicationGroups().size());
        if (describeReplicationGroupsResult.getReplicationGroups().size() == 0) {
            return null;
        }

        // Only one replication group will be returned as we have specified the replication group ID
        final Endpoint cacheEndpoint = describeReplicationGroupsResult.getReplicationGroups().get(0)
                .getConfigurationEndpoint();
        System.out.println(describeReplicationGroupsResult.getReplicationGroups().get(0));
        System.out.println("found cache endpoint manually");
        System.out.println(cacheEndpoint);
        System.out.println(cacheEndpoint.getAddress());
        System.out.println(cacheEndpoint.getPort());
        System.out.println("------");
        return new HostAndPort(cacheEndpoint.getAddress(), cacheEndpoint.getPort());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



BDB-701-Moving-From-Transactional-to-Stateful-Batch-Processing/lambda/src/main/java/com/amazon/aws/blog/StateIndexerLambdaImpl.java [279:296]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        final DescribeReplicationGroupsResult describeReplicationGroupsResult =
                elastiCache.describeReplicationGroups(describeReplicationGroupsRequest);

        System.out.println("found num groups: " + describeReplicationGroupsResult.getReplicationGroups().size());
        if (describeReplicationGroupsResult.getReplicationGroups().size() == 0) {
            return null;
        }

        // Only one replication group will be returned as we have specified the replication group ID
        final Endpoint cacheEndpoint = describeReplicationGroupsResult.getReplicationGroups().get(0)
                .getConfigurationEndpoint();
        System.out.println(describeReplicationGroupsResult.getReplicationGroups().get(0));
        System.out.println("found cache endpoint manually");
        System.out.println(cacheEndpoint);
        System.out.println(cacheEndpoint.getAddress());
        System.out.println(cacheEndpoint.getPort());
        System.out.println("------");
        return new HostAndPort(cacheEndpoint.getAddress(), cacheEndpoint.getPort());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -