[jira] [Created] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials

2017-12-23 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-8315:
-

 Summary: Use AWSCredentialsProvider to get AWS credentials
 Key: FLINK-8315
 URL: https://issues.apache.org/jira/browse/FLINK-8315
 Project: Flink
  Issue Type: New Feature
  Components: Kinesis Connector
Reporter: Ivan Mushketyk
Priority: Minor


Instead of providing credentials like:

{code:java}
Properties consumerConfig = new Properties();
consumerConfig.put(ConsumerConfigConstants.AWS_REGION, "us-east-1");
consumerConfig.put(ConsumerConfigConstants.AWS_ACCESS_KEY_ID, "...");
consumerConfig.put(ConsumerConfigConstants.AWS_SECRET_ACCESS_KEY, 
"...");
consumerConfig.put(ConsumerConfigConstants.STREAM_INITIAL_POSITION, 
"TRIM_HORIZON");
{code}

Kinesis connector could use the AWSCredentialsProvider interface.

I can contribute it myself, but I wonder if this feature makes sense to you.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Created] (FLINK-8314) Add support for Kinesis Firehose

2017-12-23 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-8314:
-

 Summary: Add support for Kinesis Firehose
 Key: FLINK-8314
 URL: https://issues.apache.org/jira/browse/FLINK-8314
 Project: Flink
  Issue Type: New Feature
  Components: Kinesis Connector
Reporter: Ivan Mushketyk
Priority: Minor


[Kinesis 
Firehose|https://docs.aws.amazon.com/firehose/latest/dev/what-is-this-service.html]
 is another product in Kinesis Family that allows zero-ops scalable stream for 
delivering streaming data to S3, RedShift, Elasticsearch, etc. It has a 
different 
[API|http://docs.aws.amazon.com/firehose/latest/APIReference/Welcome.html].

I can contribute this myself, but I wonder if this feature makes sense to you.




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

[jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties

2016-12-18 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5362:
-

 Summary: Implement methods to access BipartiteGraph properties
 Key: FLINK-5362
 URL: https://issues.apache.org/jira/browse/FLINK-5362
 Project: Flink
  Issue Type: Improvement
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5360) Fix arguments names in WindowedStream

2016-12-16 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5360:
-

 Summary: Fix arguments names in WindowedStream
 Key: FLINK-5360
 URL: https://issues.apache.org/jira/browse/FLINK-5360
 Project: Flink
  Issue Type: Bug
Reporter: Ivan Mushketyk


Should be "field" instead of "positionToMaxBy" in some methods.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5349) Fix code sample for Twitter connector

2016-12-15 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5349:
-

 Summary: Fix code sample for Twitter connector
 Key: FLINK-5349
 URL: https://issues.apache.org/jira/browse/FLINK-5349
 Project: Flink
  Issue Type: Bug
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk


There is a typo in code sample for Twitter connector.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5245) Add support for BipartiteGraph mutations

2016-12-03 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5245:
-

 Summary: Add support for BipartiteGraph mutations
 Key: FLINK-5245
 URL: https://issues.apache.org/jira/browse/FLINK-5245
 Project: Flink
  Issue Type: Improvement
  Components: Gelly
Reporter: Ivan Mushketyk


Implement methods for adding and removing vertices and edges similarly to Graph 
class.

Depends on https://issues.apache.org/jira/browse/FLINK-2254



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5244) Implement methods for BipartiteGraph transformations

2016-12-03 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5244:
-

 Summary: Implement methods for BipartiteGraph transformations
 Key: FLINK-5244
 URL: https://issues.apache.org/jira/browse/FLINK-5244
 Project: Flink
  Issue Type: Improvement
  Components: Gelly
Reporter: Ivan Mushketyk


BipartiteGraph should implement methods for transforming graph, like map, 
filter, join, union, difference, etc. similarly to Graph class.

Depends on: https://issues.apache.org/jira/browse/FLINK-2254



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5243) Implement an example for BipartiteGraph

2016-12-03 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5243:
-

 Summary: Implement an example for BipartiteGraph
 Key: FLINK-5243
 URL: https://issues.apache.org/jira/browse/FLINK-5243
 Project: Flink
  Issue Type: New Feature
  Components: Gelly
Reporter: Ivan Mushketyk


Should implement example for BipartiteGraph in gelly-examples project similarly 
to examples for Graph class.

Depends on this: https://issues.apache.org/jira/browse/FLINK-2254



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5242) Implement Scala API for BipartiteGraph

2016-12-03 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5242:
-

 Summary: Implement Scala API for BipartiteGraph
 Key: FLINK-5242
 URL: https://issues.apache.org/jira/browse/FLINK-5242
 Project: Flink
  Issue Type: New Feature
  Components: Gelly
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk


Should implement BipartiteGraph in flink-gelly-scala project similarly to Graph 
class.

Depends on this: https://issues.apache.org/jira/browse/FLINK-2254



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5104) Implement BipartiteGraph validator

2016-11-19 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-5104:
-

 Summary: Implement BipartiteGraph validator
 Key: FLINK-5104
 URL: https://issues.apache.org/jira/browse/FLINK-5104
 Project: Flink
  Issue Type: Sub-task
  Components: Gelly
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk


BipartiteGraph should have a validator similar to GraphValidator for Graph 
class.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4649) Implement bipartite graph metrics

2016-09-21 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4649:
-

 Summary: Implement bipartite graph metrics
 Key: FLINK-4649
 URL: https://issues.apache.org/jira/browse/FLINK-4649
 Project: Flink
  Issue Type: Sub-task
  Components: Gelly
Reporter: Ivan Mushketyk


Implement metrics calculation for a bipartite graph. Should be similar to 
EdgeMetrics and VertexMetrics



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4648) Implement bipartite graph generators

2016-09-21 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4648:
-

 Summary: Implement bipartite graph generators
 Key: FLINK-4648
 URL: https://issues.apache.org/jira/browse/FLINK-4648
 Project: Flink
  Issue Type: Sub-task
  Components: Gelly
Reporter: Ivan Mushketyk


Implement generators for bipartite graphs.
Should implement at least:
* *BipartiteGraphGenerator* (maybe requires a better name) that will generate a 
bipartite graph where every vertex of one set is connected only to some 
vertices  from another set
* *CompleteBipartiteGraphGenerator* that will generate a graph where every 
vertex of one set is conneted to every vertex of another set




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4647) Implement BipartiteGraph reader

2016-09-21 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4647:
-

 Summary: Implement BipartiteGraph reader
 Key: FLINK-4647
 URL: https://issues.apache.org/jira/browse/FLINK-4647
 Project: Flink
  Issue Type: Sub-task
  Components: Gelly
Reporter: Ivan Mushketyk


Implement reading bipartite graph from a CSV. Should be similar to how regular 
graph is read from a file.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4646) Add BipartiteGraph class

2016-09-21 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4646:
-

 Summary: Add BipartiteGraph class
 Key: FLINK-4646
 URL: https://issues.apache.org/jira/browse/FLINK-4646
 Project: Flink
  Issue Type: Sub-task
Reporter: Ivan Mushketyk






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode

2016-08-28 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4521:
-

 Summary: Fix "Submit new Job" panel in development mode
 Key: FLINK-4521
 URL: https://issues.apache.org/jira/browse/FLINK-4521
 Project: Flink
  Issue Type: Bug
  Components: Webfrontend
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk


If web frontend is started in the development mode, "Submit new Job" panel is 
empty.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-21 Thread Ivan Mushketyk (JIRA) 
Ivan Mushketyk created FLINK-4440:
-

 Summary: Make API for edge/vertex creation less verbose
 Key: FLINK-4440
 URL: https://issues.apache.org/jira/browse/FLINK-4440
 Project: Flink
  Issue Type: Improvement
  Components: Gelly
Reporter: Ivan Mushketyk
Assignee: Ivan Mushketyk
Priority: Trivial


It would be better if one could create vertex/edges like this:

{code:java}
Vertex v = Vertex.create(42);
Edge e = Edge.create(5, 6);
{code}

Instead of this:
{code:java}
Vertex v = new Vertex(42, 
NullValue.getInstance());
Edge e = new Edge(5, 
6, NullValue.getInstance());
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)