{"push_id":962649432,"size":8,"distinct_size":8,"ref":"refs/heads/master","head":"1198664cb35f377bbda3d9846cf6c35d232d813a","before":"680c2c3ec898ccbe469ba1fb295c948749b801ab","commits":[{"sha":"caf46728045c0b886e6d4ec0aa429a830740a391","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3201] Enhance Partitioned State Interface with State Types\n\nAdd new state types ValueState, ListState and ReducingState, where\nListState and ReducingState derive from interface MergingState.\n\nValueState behaves exactly the same as OperatorState. MergingState is a\nstateful list to which elements can be added and for which the elements\nthat it contains can be obtained. If using a ListState the list of\nelements is actually kept, for a ReducingState a reduce function is used\nto combine all added elements into one. To create a ValueState the user\npasses a ValueStateIdentifier to\nStreamingRuntimeContext.getPartitionedState() while they would pass a\nListStateIdentifier or ReducingStateIdentifier for the other state\ntypes.\n\nThis change is necessary to give the system more information about the\nnature of the operator state. We want this to be able to do incremental\nsnapshots. This would not be possible, for example, if the user had a\nList as a state. Inside OperatorState this list would be opaque and\nFlink could not create good incremental snapshots.\n\nThis also refactors the StateBackend. Before, the logic for partitioned\nstate was spread out over StreamingRuntimeContext,\nAbstractStreamOperator and StateBackend. Now it is consolidated in\nStateBackend.\n\nThis also adds support for partitioned state in two-input operators.","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/caf46728045c0b886e6d4ec0aa429a830740a391"},{"sha":"67ca4a436daf8de1a6e0329b4b30342e77d26087","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3200] Use Partitioned State in WindowOperator\n\nThis changes window operator to use the new partitioned state\nabstraction for keeping window contents instead of custom internal\nstate and the checkpointed interface.\n\nFor now, timers are still kept as custom checkpointed state, however.\n\nWindowOperator now expects a StateIdentifier for MergingState, this can\neither be for ReducingState or ListState but WindowOperator is agnostic\nto the type of State. Also the signature of WindowFunction is changed to\ninclude the type of intermediate input. For example, if a ReducingState\nis used the input of the WindowFunction is T (where T is the input\ntype). If using a ListState the input of the WindowFunction would be of\ntype Iterable[T].","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/67ca4a436daf8de1a6e0329b4b30342e77d26087"},{"sha":"524e56bcbf9faf4b7363abfefeb3b3fa53949bad","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3278] Add Partitioned State Backend Based on RocksDB","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/524e56bcbf9faf4b7363abfefeb3b3fa53949bad"},{"sha":"6f75596112ba5d36d88cc7c2de74acee8f683ca9","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3201] Add operator state to make change backwards compatible","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/6f75596112ba5d36d88cc7c2de74acee8f683ca9"},{"sha":"e4d05f72e91f03e4f350cf42c31c5ec85fe86c53","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3312] Add accessors for various state types to RuntimeContext","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/e4d05f72e91f03e4f350cf42c31c5ec85fe86c53"},{"sha":"456d0abaf7722ab16d91c5e2b52d80c076513921","author":{"email":"053520384a0ea670db2d31d536af97669647c081@gmail.com","name":"Aljoscha Krettek"},"message":"[FLINK-3200] Fix Triggers by introducing clear() method to clean up state/triggers","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/456d0abaf7722ab16d91c5e2b52d80c076513921"},{"sha":"180cd3f608731208f5b5ed71e3eb80ae5ccdf5fc","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3312] Add simple constructors for State Descriptors","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/180cd3f608731208f5b5ed71e3eb80ae5ccdf5fc"},{"sha":"1198664cb35f377bbda3d9846cf6c35d232d813a","author":{"email":"55535687dad626de987465d57be5008b6e327a91@apache.org","name":"Stephan Ewen"},"message":"[FLINK-3201] Adjust CEP code for changes state interfaces","distinct":true,"url":"https://api.github.com/repos/apache/flink/commits/1198664cb35f377bbda3d9846cf6c35d232d813a"}]}