Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove Flink dependency for store instance #909

Closed
chpengzh opened this issue Jul 27, 2018 · 1 comment
Closed

Remove Flink dependency for store instance #909

chpengzh opened this issue Jul 27, 2018 · 1 comment
Assignees
Labels
store Gradoop Store

Comments

@chpengzh
Copy link
Contributor

GradoopStoreConfig instance maybe passed from process to process(flink driver to worker), for example, I can create a store instance in mapPartition function by passing a store config.
So it must be serializable, but now it is not (for its membership flink env)

Either make ExecutionEnvironment in GradoopFlinkConfig transient or just remove extend relationship between GradoopFlinkConfig and GradoopStoreConfig.

A store instance is now independent from flink env, I vote the second.

@chpengzh
Copy link
Contributor Author

Thus the creation of a store based DataSource will be like this:

 public HBaseDataSource(
    @Nonnull GradoopFlinkConfig flinkConfig,
    @Nonnull HBaseEPGMStore epgmStore
 )

chpengzh added a commit to chpengzh/gradoop that referenced this issue Jul 27, 2018
@chpengzh chpengzh changed the title Remove Flink dependency from store instance Remove Flink dependency for store instance Jul 27, 2018
@ChrizZz110 ChrizZz110 added the store Gradoop Store label Jul 30, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Jul 30, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Jul 30, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Jul 30, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Jul 31, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Aug 1, 2018
chpengzh added a commit to chpengzh/gradoop that referenced this issue Aug 2, 2018
ChrizZz110 pushed a commit that referenced this issue Aug 24, 2018
### Release 0.4.1

* [#877] added support for property value null (#908)

fixes #877

* [#856] property pushdown hbase (#906)

fixes #856

* [#864] Change examples to use csv (#905)

fixes #864

* [#494] Add Set support to PropertyValue (#916)

fixes #494

* [#888] Minor changes to Tuple-related functions. (#912)

fixes #888

* [#779] Add code coverage for Gradoop (#914)

fixes #779

* [#702] Add support for graphs without edges to TLFDataSource (#921)

fixes #702

* [#909] Remove Flink dependency for store instance (#918)

fixes #909

* [#876] added print for logical graph and graph collection (#913)

fixes #876

* [#857] logical predicate chaining hbase (#920)

fixes #857

* [#926] added argLine to maven properties (fix ide testing bug) (#929)

fixes #926

* [#794] include new benchmark classes (#904)

fixes #794

* [#312] example program for aggregation (#925)

fixes #312

* [#901] Add SamplingConstants, AggregationConstants (#934)

fixed #901

* [#935] Add tests for containment functions (#941)

fixes #935

* [#900] Refactor sampling tests. (#907)

fixes #900

* [#936] Generalized RollUp and DrillDown (#939)

fixes #936

* [#947] Fix PageRank wrapper and add a test. (#949)

fixes #947

* [#942] graph density computation for sampling evaluation (#946)

fixes #942

* [#954] prepare minor release (#955)

fixes #954
0x002A pushed a commit to ChrizZz110/gradoop that referenced this issue Feb 19, 2019
### Release 0.4.1

* [dbs-leipzig#877] added support for property value null (dbs-leipzig#908)

fixes dbs-leipzig#877

* [dbs-leipzig#856] property pushdown hbase (dbs-leipzig#906)

fixes dbs-leipzig#856

* [dbs-leipzig#864] Change examples to use csv (dbs-leipzig#905)

fixes dbs-leipzig#864

* [dbs-leipzig#494] Add Set support to PropertyValue (dbs-leipzig#916)

fixes dbs-leipzig#494

* [dbs-leipzig#888] Minor changes to Tuple-related functions. (dbs-leipzig#912)

fixes dbs-leipzig#888

* [dbs-leipzig#779] Add code coverage for Gradoop (dbs-leipzig#914)

fixes dbs-leipzig#779

* [dbs-leipzig#702] Add support for graphs without edges to TLFDataSource (dbs-leipzig#921)

fixes dbs-leipzig#702

* [dbs-leipzig#909] Remove Flink dependency for store instance (dbs-leipzig#918)

fixes dbs-leipzig#909

* [dbs-leipzig#876] added print for logical graph and graph collection (dbs-leipzig#913)

fixes dbs-leipzig#876

* [dbs-leipzig#857] logical predicate chaining hbase (dbs-leipzig#920)

fixes dbs-leipzig#857

* [dbs-leipzig#926] added argLine to maven properties (fix ide testing bug) (dbs-leipzig#929)

fixes dbs-leipzig#926

* [dbs-leipzig#794] include new benchmark classes (dbs-leipzig#904)

fixes dbs-leipzig#794

* [dbs-leipzig#312] example program for aggregation (dbs-leipzig#925)

fixes dbs-leipzig#312

* [dbs-leipzig#901] Add SamplingConstants, AggregationConstants (dbs-leipzig#934)

fixed dbs-leipzig#901

* [dbs-leipzig#935] Add tests for containment functions (dbs-leipzig#941)

fixes dbs-leipzig#935

* [dbs-leipzig#900] Refactor sampling tests. (dbs-leipzig#907)

fixes dbs-leipzig#900

* [dbs-leipzig#936] Generalized RollUp and DrillDown (dbs-leipzig#939)

fixes dbs-leipzig#936

* [dbs-leipzig#947] Fix PageRank wrapper and add a test. (dbs-leipzig#949)

fixes dbs-leipzig#947

* [dbs-leipzig#942] graph density computation for sampling evaluation (dbs-leipzig#946)

fixes dbs-leipzig#942

* [dbs-leipzig#954] prepare minor release (dbs-leipzig#955)

fixes dbs-leipzig#954
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
store Gradoop Store
Projects
None yet
Development

No branches or pull requests

2 participants