{"push_id":1029263509,"size":45,"distinct_size":1,"ref":"refs/heads/master","head":"f09d68a05efb4afeb7b8498d35201e8324d6c096","before":"6968d07df91a40e9078e5ca39a5f67d3c3267f4a","commits":[{"sha":"9381c430faf0e197bb2c96c7e418d33725e487f6","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3223] Translate Table API calls to Calcite RelNodes.\n\nThis is an intermediate step to port the Table API on top of Calcite (FLINK-3221).\nThis commit:\n- Adds Calcite as dependency to flink-table.\n- Translates Table API calls directly into Calcite RelNodes.\n- Modifies tests to check only the translation into logical plans but not the execution of Table API queries.\n- Deactivates a few tests that are not supported yet.\n- Removes a lot of the former Table API translation code.\n- Removes bitwise operators from the Table API.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/9381c430faf0e197bb2c96c7e418d33725e487f6"},{"sha":"71a7d20b414028f9349ed3becbf6a2fc5142096a","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"Renamed Table.scala to table.scala","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/71a7d20b414028f9349ed3becbf6a2fc5142096a"},{"sha":"d0611b9ea32b522f9ca1b5341797850266f77c15","author":{"email":"5cbbd5f57bb27bf0f9da21420242788d85005e91@intel.com","name":"chengxiang li"},"message":"[FLINK-3282] add FlinkRelNode interface.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/d0611b9ea32b522f9ca1b5341797850266f77c15"},{"sha":"dee1876bff2b9e88a4111d1e7c3180055de53b37","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3225] Implemented optimization of Table API queries via Calcite\n\n- added logical Flink nodes and translation rules\n- added stubs for DataSet translation rules\n- ported DataSetNodes to Scala\n- reactivated tests and added expected NotImplementedError","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/dee1876bff2b9e88a4111d1e7c3180055de53b37"},{"sha":"5388d7baf267c59c6af5fac5eca4369e518fd0d6","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3225] Enforce translation to DataSetNodes","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/5388d7baf267c59c6af5fac5eca4369e518fd0d6"},{"sha":"5b28a50dd1b111ed8e18aee8919b322e1ce9b983","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3226] Add DataSet scan and  conversion to DataSet[Row]\n\nThis closes #1579.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/5b28a50dd1b111ed8e18aee8919b322e1ce9b983"},{"sha":"ba27832fca09e6d01aac4ce21ffa93f83830531a","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Implement a CodeGenerator for an efficient translation to DataSet programs\n\nThis closes #1595","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/ba27832fca09e6d01aac4ce21ffa93f83830531a"},{"sha":"b8028dbc5f53edce2b337bd14c47feace39d0fbb","author":{"email":"5cbbd5f57bb27bf0f9da21420242788d85005e91@intel.com","name":"chengxiang li"},"message":"[Flink-3226] Translate logical plan FlinkRels into physical plan DataSetRels.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/b8028dbc5f53edce2b337bd14c47feace39d0fbb"},{"sha":"7972426e40b50bd963f6f895b9755c7408baff5a","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3226] implement GroupReduce translation; enable tests for supported operations\n\nSquashes the following commits:\n- Compute average as sum and count for byte, short and int type to avoid rounding errors\n- Move aggregation functions to org.apache.flink.table.runtime\n- Remove join-related changes\n- Change integer average aggregations to maintain sum and count\n- Long average uses a BigInteger sum","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/7972426e40b50bd963f6f895b9755c7408baff5a"},{"sha":"670ec6af0cd6d7e91a3ec08f653f45b0c744df61","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3226] implement getUniqueName method in TranslationContext\n\nThis closes #1600 and #1567","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/670ec6af0cd6d7e91a3ec08f653f45b0c744df61"},{"sha":"f89d303e99c1214b75425497b331191b6dc9e2b8","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3226] Translate logical joins to physical\n\nThis closes #1632","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/f89d303e99c1214b75425497b331191b6dc9e2b8"},{"sha":"7a46bfac526d7827b31e2c7139e461d8a8237311","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Translation from and to POJOs for CodeGenerator\n\nThis closes #1624","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/7a46bfac526d7827b31e2c7139e461d8a8237311"},{"sha":"f05f8fb4443012d9f81233eafef97d8c47de311b","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Casting support for arithmetic operators","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/f05f8fb4443012d9f81233eafef97d8c47de311b"},{"sha":"907a0957e93a51a3e08ca81dcf183d7079346d6f","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Translation of explicit casting","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/907a0957e93a51a3e08ca81dcf183d7079346d6f"},{"sha":"674fcc269d44f0fb17896286c95ba26fe0feb35e","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Translation of scalar function substring()","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/674fcc269d44f0fb17896286c95ba26fe0feb35e"},{"sha":"10d3a3119a3057f83dad3956a03a6a2e4ab52fee","author":{"email":"5cbbd5f57bb27bf0f9da21420242788d85005e91@intel.com","name":"chengxiang li"},"message":"[FLINK-3508] Add more test cases to verify the rules of logical plan optimization.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/10d3a3119a3057f83dad3956a03a6a2e4ab52fee"},{"sha":"3e3f07629e8d3f39090282bb279484d3dce85a30","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3463] implement calc translation\n\n- remove FlinkFilter, FlinkProject and associated rules\n\n- deactivate FilterReduceExpressionsRule and ProjectReduceExpressionsRule\n  (covered by CalcReduceExpressions)\n\nThis closes #1696","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/3e3f07629e8d3f39090282bb279484d3dce85a30"},{"sha":"b5d6a564895095459c368cad6069df07b7c0382b","author":{"email":"50f957e7ebf7b4286b7f73838f5eec431c788506@apache.org","name":"twalthr"},"message":"[FLINK-3226] Improvements for expected types\n\nThis closes #1709","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/b5d6a564895095459c368cad6069df07b7c0382b"},{"sha":"4f6b91ecda2c3fdeb8930f49c0913f85f8605061","author":{"email":"6873ed71afbc9d34f235a1376a902115740ccfeb@apache.org","name":"vasia"},"message":"[FLINK-3482] implement union translation\n- implement custom JoinUnionTransposeRules\nbecause Calcite's only match with LogicalUnion\n\nThis closes #1715","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/4f6b91ecda2c3fdeb8930f49c0913f85f8605061"},{"sha":"ab16e3c32b4d8d538b526370f4e7262f894f1a2e","author":{"email":"3a056086720937832f35986dba7520b3ca5fa808@apache.org","name":"Fabian Hueske"},"message":"[FLINK-3502] Add test case. Bug was resolved by a previous commit.","distinct":false,"url":"https://api.github.com/repos/mbalassi/flink/commits/ab16e3c32b4d8d538b526370f4e7262f894f1a2e"}]}