flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kailash Hassan Dayanand (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-8945) Allow customization of the KinesisProxy Interface
Date Wed, 14 Mar 2018 16:08:00 GMT
Kailash Hassan Dayanand created FLINK-8945:

             Summary: Allow customization of the KinesisProxy Interface
                 Key: FLINK-8945
                 URL: https://issues.apache.org/jira/browse/FLINK-8945
             Project: Flink
          Issue Type: Improvement
            Reporter: Kailash Hassan Dayanand

Currently the KinesisProxy interface here:


has a private constructor. This restricts extending the class and prevents customizations
on shard discovery. I am proposing to change this to protected.

While the creating a new implementation of KinesisProxyInterface is possible, I would like
to continue to use implementation of getRecords and getShardIterator.

This will be a temporary workaround till FLINK-8944 is submitted. 

This message was sent by Atlassian JIRA

View raw message