Try out our Premium Member services: Virtual Legal Assistant, Query Alert Service and an ad-free experience. Free for one month and pay only if you like it.
CWP No. 12519 of 2008 [1] IN THE HIGH COURT OF PUNJAB & HARYANA AT CHANDIGARH CWP No. 12519 of 2008 Date of Decision: 20.10.2009 M/s Himalayan Frozen Foods Ltd. ..Petitioner Versus Punjab Pollution Control Board ..Respondent CORAM: HON'BLE MR. JUSTICE T.S.THAKUR,CHIEF JUSTICE HON'BLE MR. JUSTICE MAHESH GROVER 1.Whether Reporters of local papers may be allowed to see the judgment ? 2. Whether to be referred to the Reporters or not ? 3. Whether the judgment should be reported in the Digest? Present : Ms. Munisha Gandhi, Advocate, for the petitioner. Mr. D.S.Patwalia, Advocate, for the respondent. *****
T.S.Thakur, C.J. (Oral) This petition for a writ of certiorari calls in question the correctness of an order dated 3.7.2008 passed by the Punjab Pollution Control Board whereby the petitioner company was directed to submit a bank guarantee for a sum of Rs. 10 lacs valid for a period of one year to ensure regular operation and maintenance of its Effluent Treatment CWP No. 12519 of 2008 [2] Plant for compliance with effluents standards prescribed for the industry in question. The controversy arises in the following backdrop.
The petitioner company has set up a medium scale industrial unit at village Rajgarh, Tehsil Rajpura, District Patiala which is engaged primarily in manufacturing and marketing of processed/frozen foods. The petitioner's case is that the industry set up by it is seasonal in nature and operates only for a period of two or three months in a calendar year. Its further case is that the sister concern of the petitioner company by the name M/s Green Bagh Foods Limited is also engaged in manufacture of Jams and Tomato Ketchup and is located in the same premises but remains operational almost throughout the year. Since both the companies referred to above are required to have an Effluent Treatment Plant in terms of the statutes in force, the petitioner company appears to have set up a Common Effluent Treatment Plant for treating the effluents discharged from their respective units. While the petitioner's case is that Effluent Treatment Plant so installed is functional and maintains standards stipulated for that purpose, the respondent Board disputes that assertion.
According to the respondent Board, the industry set up by the petitioner company was visited by its officers on 01.02.2008 when it was observed that the Effluent Treatment Plant installed by the industry was not in operation and that untreated effluent was being discharged onto the adjacent land for stagnation. The inspection also revealed the presence of untreated effluents in the adjacent land, a sample whereof was also collected by the officer conducting the inspection for analysis. The test reports revealed that the effluents CWP No. 12519 of 2008 [3] discharged by the unit were beyond permissible limit prescribed by the Board. Acting on that basis, the Board appears to have taken the view that the petitioner company was in default of the requirements of the Water (Prevention & Control of Pollution) Act, 1974, resulting in the issue of the order impugned in this petition whereby the industry has been directed to submit a bank guarantee for a sum of Rs. 10 lacs valid for a period of one year and to maintain and operate the Effluent Treatment Plant and ensure that effluent standards prescribed are not violated. Aggrieved, the petitioner-company has assailed the correctness of the said directions in the present petition.
We have heard learned counsel for the parties at a considerable length and perused the record.
Mr. Patwalia, learned counsel appearing for the Board submitted, and in our opinion rightly so, that this petition has with the passage of time become infructuous and the issues raised therein rendered academic. He further submits that the order in question requiring the petitioner's unit to furnish a bank guarantee for a sum of Rs. 10 lacs for a period of one year, necessarily means that the bank guarantee, if furnished in terms of the said order, would be valid only till 31.07.2009. He further argued that since consent to operate has to be obtained by every industrial unit on an annual basis and an application for such consent has to be filed two months before the expiry of the consent earlier granted, the petitioner company will have to file an application for grant of consent for the year 2010, in which event, the Board would examine the issue and pass a fresh order on the subject in accordance with law. He urged that the petitioner could be directed to CWP No. 12519 of 2008 [4] make such an application within two weeks from today, in which event the competent authority in the Board would pass an appropriate order on the subject within two weeks thereafter. All other issues raised by the petitioner's unit could in that view be left open to be agitated at an appropriate stage, if the occasion to do so arise.
Ms. Gandhi, learned counsel appearing for the petitioner unit had no serious objection to that procedure being followed. She submitted that while the petitioner company is ready and willing to make an application for the grant of consent to operate for the year 2010, the Board ought to dispose of the said request quickly so that the petitioner's working for the remainder of the current year is not affected. She further submitted that the petitioner's unit has installed an Effluent Treatment Plant although the same is common to its sister concern M/s Green Bagh Foods Ltd. and that it would ensure that the said plant is not only functional but also serves the purpose for which it has been installed.
In the circumstances, therefore, it is unnecessary for us to go into the question whether the order passed by Environmental Engineer of the Punjab Pollution Control Board demanding a bank guarantee of Rs. 10 lacs suffered from any error of law or procedure. Since the period for which the said guarantee was to be furnished has already expired, the entire issue regarding the validity of that order appears to have become academic. It is also obvious that the unit cannot operate without proper consent from the Board. The request of the petitioner for grant of consent for the year 2009 appears to have been filed after the passing of impugned order and has remained pending CWP No. 12519 of 2008 [5] before the Board ostensibly because of the pendency of the present writ petition. In that view, therefore, any order which the competent authority in the Board may pass on the application filed by the petitioner for the grant of consent to operate should work to the benefit of the unit from the date the order is made not necessarily w.e.f. 01.01.2010.
In fairness to Mr. Patwalia, we must mention that he had no quarrel with that proposition and submitted that if an order granting consent is made the same can be effective for a period of one year from the date it is issued.
In the result, we dispose of this writ petition with the following directions:-
i) Upon receipt of an application, the competent authority in the Pollution Control Board shall afford to the petitioner an opportunity of being heard in the matter and pass an appropriate order in accordance with law within two weeks thereafter.
ii) In case the competent authority decides to grant consent to operate conditionally or otherwise, the same shall became operative from the date the order is made and shall continue to remain operative for the period mentioned in the order.
iii) In case the consent is refused, the petitioner's unit shall have the liberty to seek appropriate redress against the refusal in appropriate proceedings before the appropriate Forum.
CWP No. 12519 of 2008 [6] All other questions raised by the parties in these proceedings are left open to be determined in appropriate proceedings, if an occasion to do so arises. No costs.
A copy of the order shall be given dasti to Ms. Gandhi under the signature of the Bench Secretary.
(T.S.THAKUR) CHIEF JUSTICE (MAHESH GROVER) JUDGE 20.10.2009 'ravinder'


CSS-Tricks Example
Image behind
Placeholder text (HTML5)
Placeholder text (jQuery + HTML5)
Remember, be nice!
Remove Glow (from WebKit)
Remove Resize Handle (from WebKit)
Add Resize Handle (jQuery UI)
Auto Resize
Nowrap
Remove Scrollbars (from IE)


MUCSC - Details
Submission date changed to February 12!
The due date for submissions has been moved to Thursday, February 12th to provide additional time for this announcement to proliferate. Already submitted abstracts and papers may be revised and resubmitted, if desired. We will still notify presenters by March 4th.
We would like to reiterate that all undergraduate students are welcome to attend all parts of the conference, including the keynote address by Douglas Hofstadter, regardless of whether they are presenting, and that the conference will have no registration fee. Transportation and lodging are the responsibility of attendees.
Presentations:
- Presentations will be 10-15 minutes in length, with a 5-10 minute question period after the talk. Presentations are on either Saturday or Sunday afternoons.
- Papers are to be approximately 3-6 pages in length, containing an abstract, introduction, methods, data, and analysis. You are expected to finish data collection and analysis by the conference date (April 4). A strong preference will be given to papers with completed analysis.
Posters:
- Poster presentations will occur Saturday night, following the keynote.
- Abstracts for poster submissions should include a title, brief introduction to the subject matter, and a brief overview of the project.
General:
- Assisting faculty or mentors should be listed either as co-authors or in an acknowledgements section, depending on the level of their contribution to the students original research.
- Literature reviews are welcome, although priority will be given to original research.
Thank you,
Nicole Beckage
Jaimie Murdock
Jordan Thevenow-Harrison
Co-chairs Midwest Undergraduate Cognitive Science Conference.
<EMAIL_ADDRESS>http://www.indiana.edu/~iusocs/mucsc/


Created a C++ library to register, distribute and receive Remote Procedure Calls.
Learn moreA program that can learn and classify articles using Scikit-learn.
Learn moreA program that can learn and classify articles implementing a modified Naïve Bayes algorithm.
Learn moreI'm currently in my fourth year of Computer Science at the University of Waterloo, but if you have an interesting internship position for Spring 2018, I'd love to hear all about it!
If you have any interesting work, or just want to connect, feel free to email me at<EMAIL_ADDRESS>any time.


| Home | Trees | Indices | Help |
|
|---|
|
|
object --+ | Cameras
Base class for the interface to the robot's Cameras.
|
|||
|
|||
| bool |
|
||
| [str] |
|
||
| bool |
|
||
| bool |
|
||
|
|||
| bool |
|
||
| bool |
|
||
|
Inherited from |
|
|||
|
Inherited from |
|
Constructor.
|
Private function to check if the camera is currently in streaming mode.
|
Return the list of all camera names on current robot.
|
Verify if the given camera name is in the list of camera names or not.
|
Check the given camera name is streaming or not.
|
Setup the callback function to show image.
|
Start camera streaming for the given camera name, This only allows one camera open at one time and forces closed any other open cameras before open the wanted one.
|
Stop camera streaming by given the camera name.
|
| Home | Trees | Indices | Help |
|
|---|
| Generated by Epydoc 3.0.1 on Tue Dec 6 15:22:10 2016 | http://epydoc.sourceforge.net |


--- layout: post title: Tea date: '2003-03-10T12:00:00-05:00' tags: - '2003' tumblr_url: http://poetry.liabogoev.com/post/913870112/tea ---
Tea sounds as wonderful
as it really is
You relax with it when
everyone’s all abuzz
When you get back from skiing
with smelly socks and a movie,
Tea right then is really
quite groovy
When you drink it up
it sits warm in your tummy
It makes you all toasty
I like tea, yummy!


Here you can publish an announcement to all credential participants. New Announcement New Announcement
There are no announcements.


Release 1.2.0 – Changelog
Changelog
The 1.2.0 release resolved 650 JIRA issues in total.
Sub-task
- [FLINK-3202] - Make Timer/Trigger Service Scoped to Key/Namespace
- [FLINK-3580] - Reintroduce Date/Time and implement scalar functions for it
- [FLINK-3660] - Measure latency of elements and expose it as a metric
- [FLINK-3761] - Refactor State Backends/Make Keyed State Key-Group Aware
- [FLINK-3950] - Add Meter Metric Type
- [FLINK-4174] - Enhance Window Evictor
- [FLINK-4221] - Show metrics in WebFrontend
- [FLINK-4273] - Refactor JobClientActor to watch already submitted jobs
- [FLINK-4312] - Remove Serializabiliy of ExecutionGraph
- [FLINK-4317] - Restructure documentation layout
- [FLINK-4320] - Fix misleading ScheduleMode names
- [FLINK-4324] - Enable Akka SSL
- [FLINK-4325] - Implement Web UI HTTPS
- [FLINK-4380] - Introduce KeyGroupAssigner and Max-Parallelism Parameter
- [FLINK-4381] - Refactor State to Prepare For Key-Group State Backends
- [FLINK-4384] - Add a "scheduleRunAsync()" feature to the RpcEndpoint
- [FLINK-4386] - Add as way to assert that code runs in the RpcEndpoint's Main Thread
- [FLINK-4389] - Expose metrics to Webfrontend
- [FLINK-4392] - Make RPC Service Thread Safe
- [FLINK-4403] - RPC proxy classloading should use Flink class' classloader
- [FLINK-4404] - Implement Data Transfer SSL
- [FLINK-4405] - Implement Blob Server SSL
- [FLINK-4434] - Add a testing RPC service
- [FLINK-4490] - Decouple Slot and Instance
- [FLINK-4507] - Deprecate savepoint backend config
- [FLINK-4509] - Specify savepoint directory per savepoint
- [FLINK-4510] - Always create CheckpointCoordinator
- [FLINK-4512] - Add option for persistent checkpoints
- [FLINK-4670] - Add watch mechanism on current RPC framework
- [FLINK-4685] - Gather operator checkpoint durations data sizes from the runtime
- [FLINK-4691] - Add group-windows for streaming tables
- [FLINK-4697] - Gather more detailed checkpoint stats in CheckpointStatsTracker
- [FLINK-4698] - Visualize additional checkpoint information
- [FLINK-4748] - Fix shutdown of automatic watermark context
- [FLINK-4749] - Remove redundant processing time timers and futures in the window operator
- [FLINK-4750] - Ensure that active processing time triggers complete before closing operators
- [FLINK-4768] - Migrate High Availability configuration options
- [FLINK-4826] - Add keytab based kerberos support for Mesos environment
- [FLINK-4877] - Refactorings around FLINK-3674 (User Function Timers)
- [FLINK-4884] - Eagerly Store MergingWindowSet in State in WindowOperator
- [FLINK-4899] - Implement DCOS package
- [FLINK-4900] - Implement Docker image support
- [FLINK-4901] - Build DCOS Docker image
- [FLINK-4918] - Add SSL support to Mesos artifact server
- [FLINK-4921] - Upgrade to Mesos 1.0.1
- [FLINK-4922] - Write documentation
- [FLINK-4937] - Add incremental group window aggregation for streaming Table API
- [FLINK-4959] - Write Documentation for ProcessFunction
- [FLINK-4984] - Add Cancellation Barriers to BarrierTracker and BarrierBuffer
- [FLINK-4985] - Report Declined/Canceled Checkpoints to Checkpoint Coordinator
- [FLINK-4987] - Harden slot pool logic
- [FLINK-4993] - Don't Allow Trigger.onMerge() to return TriggerResult
- [FLINK-4994] - Don't Clear Trigger State and Merging Window Set When Purging
- [FLINK-5042] - Convert old savepoints to new savepoints
- [FLINK-5043] - Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2
- [FLINK-5044] - Converting operator and function state from Flink 1.1 for all changed operators in 1.2
- [FLINK-5091] - Formalize the AppMaster environment for docker compability
- [FLINK-5290] - Ensure backwards compatibility of the hashes used to generate JobVertexIds
- [FLINK-5293] - Make the Kafka consumer backwards compatible.
- [FLINK-5294] - Make the WindowOperator backwards compatible.
- [FLINK-5295] - Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible.
- [FLINK-5317] - Make the continuous file processing code backwards compatible,
- [FLINK-5318] - Make the Rolling sink backwards compatible.
- [FLINK-5386] - Refactoring Window Clause
- [FLINK-5454] - Add Documentation about how to tune Checkpointing for large state
- [FLINK-5455] - Create documentation how to upgrade jobs and Flink framework versions
- [FLINK-5456] - Add docs about new state and checkpointing interfaces
- [FLINK-5457] - Create documentation for Asynchronous I/O
- [FLINK-5458] - Add documentation how to migrate from Flink 1.1. to Flink 1.2
- [FLINK-5459] - Add documentation how to debug classloading issues
- [FLINK-5460] - Add documentation how to use Flink with Docker
- [FLINK-5474] - Extend DC/OS documentation
- [FLINK-5494] - Improve Mesos documentation
- [FLINK-5502] - Add documentation about migrating functions from 1.1 to 1.2
- [FLINK-5529] - Improve / extends windowing documentation
- [FLINK-5555] - Add documentation about debugging watermarks
Bug
- [FLINK-2662] - CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."
- [FLINK-2821] - Change Akka configuration to allow accessing actors from different URLs
- [FLINK-2839] - Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics
- [FLINK-3138] - Method References are not supported as lambda expressions
- [FLINK-3680] - Remove or improve (not set) text in the Job Plan UI
- [FLINK-3706] - YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable
- [FLINK-3813] - YARNSessionFIFOITCase.testDetachedMode failed on Travis
- [FLINK-3888] - Custom Aggregator with Convergence can't be registered directly with DeltaIteration
- [FLINK-3918] - Not configuring any time characteristic leads to a ClassCastException
- [FLINK-4021] - Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection
- [FLINK-4035] - Add Apache Kafka 0.10 connector
- [FLINK-4073] - YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis
- [FLINK-4081] - FieldParsers should support empty strings
- [FLINK-4100] - RocksDBStateBackend#close() can throw NPE
- [FLINK-4108] - NPE in Row.productArity
- [FLINK-4140] - CheckpointCoordinator fails to discard completed checkpoint
- [FLINK-4148] - incorrect calculation distance in QuadTree
- [FLINK-4155] - Get Kafka producer partition info in open method instead of constructor
- [FLINK-4177] - CassandraConnectorTest.testCassandraCommitter causing unstable builds
- [FLINK-4219] - Quote PDSH opts in start-cluster.sh
- [FLINK-4226] - Typo: Define Keys using Field Expressions example should use window and not reduce
- [FLINK-4236] - Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up
- [FLINK-4252] - Table program cannot be compiled
- [FLINK-4255] - Unstable test WebRuntimeMonitorITCase.testNoEscape
- [FLINK-4257] - Handle delegating algorithm change of class
- [FLINK-4259] - Unclosed FSDataOutputStream in FileCache#copy()
- [FLINK-4263] - SQL's VALUES does not work properly
- [FLINK-4270] - 'as' in front of join does not work
- [FLINK-4271] - There is no way to set parallelism of operators produced by CoGroupedStreams
- [FLINK-4276] - TextInputFormatTest.testNestedFileRead fails on Windows OS
- [FLINK-4285] - Non-existing example in Flink quickstart setup documentation
- [FLINK-4289] - Source files have executable flag set
- [FLINK-4290] - CassandraConnectorTest deadlocks
- [FLINK-4291] - No log entry for unscheduled reporters
- [FLINK-4292] - HCatalog project incorrectly set up
- [FLINK-4293] - Malformatted Apache Headers
- [FLINK-4296] - Scheduler accepts more tasks than it has task slots available
- [FLINK-4297] - Yarn client can't determine fat jar location if path contains spaces
- [FLINK-4298] - Clean up Storm Compatibility Dependencies
- [FLINK-4304] - Jar names that contain whitespace cause problems in web client
- [FLINK-4307] - Broken user-facing API for ListState
- [FLINK-4309] - Potential null pointer dereference in DelegatingConfiguration#keySet()
- [FLINK-4311] - TableInputFormat fails when reused on next split
- [FLINK-4313] - Inconsistent code for Key/Value in the CheckpointCoordinator
- [FLINK-4314] - Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown
- [FLINK-4316] - Make flink-core independent of Hadoop
- [FLINK-4323] - Checkpoint Coordinator Removes HA Checkpoints in Shutdown
- [FLINK-4329] - Fix Streaming File Source Timestamps/Watermarks Handling
- [FLINK-4332] - Savepoint Serializer mixed read()/readFully()
- [FLINK-4333] - Name mixup in Savepoint versions
- [FLINK-4337] - Remove unnecessary Scala suffix from Hadoop1 artifact
- [FLINK-4341] - Kinesis connector does not emit maximum watermark properly
- [FLINK-4342] - Fix dependencies of flink-connector-filesystem
- [FLINK-4385] - Union on Timestamp fields does not work
- [FLINK-4387] - Instability in KvStateClientTest.testClientServerIntegration()
- [FLINK-4388] - Race condition during initialization of MemorySegmentFactory
- [FLINK-4394] - RMQSource: The QueueName is not accessible to subclasses
- [FLINK-4398] - Unstable test KvStateServerHandlerTest.testSimpleQuery
- [FLINK-4409] - class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar
- [FLINK-4411] - [py] Chained dual input children are not properly propagated
- [FLINK-4412] - [py] Chaining does not properly handle broadcast variables
- [FLINK-4417] - Checkpoints should be subsumed by CheckpointID not, by timestamp
- [FLINK-4418] - ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception
- [FLINK-4425] - "Out Of Memory" during savepoint deserialization
- [FLINK-4436] - Unclosed DataOutputBuffer in Utils#setTokensFor()
- [FLINK-4437] - Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields
- [FLINK-4453] - Scala code example in Window documentation shows Java
- [FLINK-4454] - Lookups for JobManager address in config
- [FLINK-4482] - numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock
- [FLINK-4485] - Finished jobs in yarn session fill /tmp filesystem
- [FLINK-4486] - JobManager not fully running when yarn-session.sh finishes
- [FLINK-4488] - Prevent cluster shutdown after job execution for non-detached jobs
- [FLINK-4506] - CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true
- [FLINK-4514] - ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream
- [FLINK-4522] - Gelly link broken in homepage
- [FLINK-4526] - ApplicationClient: remove redundant proxy messages
- [FLINK-4544] - TaskManager metrics are vulnerable to custom JMX bean installation
- [FLINK-4556] - Make Queryable State Key-Group Aware
- [FLINK-4559] - Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"
- [FLINK-4563] - [metrics] scope caching not adjusted for multiple reporters
- [FLINK-4564] - [metrics] Delimiter should be configured per reporter
- [FLINK-4566] - ProducerFailedException does not properly preserve Exception causes
- [FLINK-4567] - Enhance SerializedThrowable to properly preserver cause chains
- [FLINK-4570] - Scalastyle Maven plugin fails undeterministically
- [FLINK-4572] - Convert to negative in LongValueToIntValue
- [FLINK-4573] - Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler
- [FLINK-4581] - Table API throws "No suitable driver found for jdbc:calcite"
- [FLINK-4586] - NumberSequenceIterator and Accumulator threading issue
- [FLINK-4588] - Fix Merging of Covering Window in MergingWindowSet
- [FLINK-4589] - Fix Merging of Covering Window in MergingWindowSet
- [FLINK-4590] - Some Table API tests are failing when debug lvl is set to DEBUG
- [FLINK-4592] - Fix flaky test ScalarFunctionsTest.testCurrentTimePoint
- [FLINK-4594] - Validate lower bound in MathUtils.checkedDownCast
- [FLINK-4601] - Check for empty string properly
- [FLINK-4603] - KeyedStateBackend cannot restore user code classes
- [FLINK-4609] - Remove redundant check for null in CrossOperator
- [FLINK-4612] - Close FileWriter using try with resources
- [FLINK-4614] - Kafka connector documentation refers to Flink 1.2-SNAPSHOT
- [FLINK-4618] - FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka
- [FLINK-4619] - JobManager does not answer to client when restore from savepoint fails
- [FLINK-4622] - CLI help message should include 'savepoint' action
- [FLINK-4624] - Gelly's summarization algorithm cannot deal with null vertex group values
- [FLINK-4626] - Missing break in MetricStore#add()
- [FLINK-4628] - User class loader unavailable during input split assignment
- [FLINK-4631] - NullPointerException during stream task cleanup
- [FLINK-4640] - Serialization of the initialValue of a Fold on WindowedStream fails
- [FLINK-4645] - Hard to register Kryo Serializers due to generics
- [FLINK-4651] - Re-register processing time timers at the WindowOperator upon recovery.
- [FLINK-4652] - Don't pass credentials explicitly to AmazonClient - use credentials provider instead
- [FLINK-4659] - Potential resource leak due to unclosed InputStream in SecurityContext#populateSystemSecurityProperties()
- [FLINK-4663] - Flink JDBCOutputFormat logs wrong WARN message
- [FLINK-4665] - Remove boxing/unboxing to parse a primitive
- [FLINK-4666] - Make constants to be final in ParameterTool
- [FLINK-4667] - Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend
- [FLINK-4671] - Table API can not be built
- [FLINK-4672] - TaskManager accidentally decorates Kill messages
- [FLINK-4677] - Jars with no job executions produces NullPointerException in ClusterClient
- [FLINK-4696] - Limit the number of Akka Dispatcher Threads in LocalMiniCluster
- [FLINK-4700] - Harden the TimeProvider test
- [FLINK-4702] - Kafka consumer must commit offsets asynchronously
- [FLINK-4708] - Scope Mini Kerberos Cluster dependencies as test dependencies
- [FLINK-4709] - InputStreamFSInputWrapper does not close wrapped stream
- [FLINK-4710] - Remove transitive Guice dependency from Hadoop
- [FLINK-4711] - TaskManager can crash due to failing onPartitionStateUpdate call
- [FLINK-4718] - Confusing label in Parallel Streams Diagram
- [FLINK-4727] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read
- [FLINK-4730] - Introduce CheckpointMetaData
- [FLINK-4731] - HeapKeyedStateBackend restoring broken for scale-in
- [FLINK-4732] - Maven junction plugin security threat
- [FLINK-4741] - WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.
- [FLINK-4743] - The sqrt/power function not accept the real data types.
- [FLINK-4744] - Introduce usercode class loader to deserialize partitionable operator state
- [FLINK-4747] - Instability due to pending processing timers on operator close
- [FLINK-4753] - Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock
- [FLINK-4774] - QueryScopeInfo scope concatenation broken
- [FLINK-4777] - ContinuousFileMonitoringFunction may throw IOException when files are moved
- [FLINK-4784] - MetricQueryService actor name collision
- [FLINK-4786] - BarrierBufferTest test instability
- [FLINK-4788] - State backend class cannot be loaded, because fully qualified name converted to lower-case
- [FLINK-4791] - Fix issues caused by expression reduction
- [FLINK-4793] - Using a local method with :: notation in Java 8 causes index out of bounds
- [FLINK-4794] - partition_by_hash() crashes if no parameter is provided
- [FLINK-4795] - CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5))
- [FLINK-4798] - CEPITCase.testSimpleKeyedPatternCEP test failure
- [FLINK-4801] - Input type inference is faulty with custom Tuples and RichFunctions
- [FLINK-4804] - Grouping.first() function usage fails
- [FLINK-4805] - Stringify() crashes with Python3 (run with pyflink3)
- [FLINK-4824] - CliFrontend shows misleading error message when main() method returns before env.execute()
- [FLINK-4827] - The scala example of SQL on Streaming Tables with wrong variable name in flink document
- [FLINK-4829] - Accumulators are not thread safe
- [FLINK-4833] - Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch
- [FLINK-4838] - remove STREAM keyword in StreamSQLExample
- [FLINK-4845] - Fix Job Exceptions page
- [FLINK-4852] - ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime
- [FLINK-4862] - NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger
- [FLINK-4866] - Make Trigger.clear() Abstract to Enforce Implementation
- [FLINK-4870] - ContinuousFileMonitoringFunction does not properly handle absolut Windows paths
- [FLINK-4872] - Type erasure problem exclusively on cluster execution
- [FLINK-4875] - operator name not correctly inferred
- [FLINK-4879] - class KafkaTableSource should be public just like KafkaTableSink
- [FLINK-4887] - Replace ActorGateway by TaskManagerGateway interface
- [FLINK-4890] - FileInputFormatTest#testExcludeFiles fails on Windows OS
- [FLINK-4907] - Add Test for Timers/State Provided by AbstractStreamOperator
- [FLINK-4932] - Don't let ExecutionGraph fail when in state Restarting
- [FLINK-4933] - ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph
- [FLINK-4941] - Show ship strategy in web interface
- [FLINK-4945] - KafkaConsumer logs wrong warning about confirmation for unknown checkpoint
- [FLINK-4967] - RockDB state backend fails on Windows
- [FLINK-4973] - Flakey Yarn tests due to recently added latency marker
- [FLINK-4977] - Enum serialization does not work in all cases
- [FLINK-4991] - TestTask hangs in testWatchDogInterruptsTask
- [FLINK-4998] - ResourceManager fails when num task slots > Yarn vcores
- [FLINK-5002] - Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers
- [FLINK-5007] - Retain externalized checkpoint on suspension
- [FLINK-5011] - TraversableSerializer does not perform a deep copy of the elements it is traversing
- [FLINK-5014] - RocksDBStateBackend misses good toString
- [FLINK-5016] - EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs
- [FLINK-5019] - Proper isRestored result for tasks that did not write state
- [FLINK-5027] - FileSource finishes successfully with a wrong path
- [FLINK-5028] - Stream Tasks must not go through clean shutdown logic on cancellation
- [FLINK-5032] - CsvOutputFormatTest fails on Windows OS
- [FLINK-5033] - CEP operators don't properly advance time
- [FLINK-5037] - Instability in AbstractUdfStreamOperatorLifecycleTest
- [FLINK-5038] - Errors in the "cancelTask" method prevent closeables from being closed early
- [FLINK-5039] - Avro GenericRecord support is broken
- [FLINK-5040] - Set correct input channel types with eager scheduling
- [FLINK-5048] - Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior
- [FLINK-5049] - Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure
- [FLINK-5050] - JSON.org license is CatX
- [FLINK-5055] - Security feature crashes JM for certain Hadoop versions even though using no Kerberos
- [FLINK-5056] - BucketingSink deletes valid data when checkpoint notification is slow.
- [FLINK-5057] - Cancellation timeouts are picked from wrong config
- [FLINK-5058] - taskManagerMemory attribute set wrong value in FlinkShell
- [FLINK-5063] - State handles are not properly cleaned up for declined or expired checkpoints
- [FLINK-5071] - YARN: yarn.containers.vcores config not respected when checking for vcores
- [FLINK-5073] - ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread
- [FLINK-5075] - Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite
- [FLINK-5082] - Pull ExecutionService lifecycle management out of the JobManager
- [FLINK-5085] - Execute CheckpointCoodinator's state discard calls asynchronously
- [FLINK-5097] - The TypeExtractor is missing input type information in some Graph methods
- [FLINK-5102] - Connection establishment does not react to interrupt
- [FLINK-5109] - Invalid Content-Encoding Header in REST API responses
- [FLINK-5111] - Change the assignToKeyGroup() method to not use Object.hashCode()
- [FLINK-5112] - Remove unused accumulator code from ArchivedExecutionJobVertex
- [FLINK-5114] - PartitionState update with finished execution fails
- [FLINK-5118] - Inconsistent records sent/received metrics
- [FLINK-5119] - Last taskmanager heartbeat not showing in web frontend
- [FLINK-5143] - Add EXISTS to list of supported operators
- [FLINK-5144] - Error while applying rule AggregateJoinTransposeRule
- [FLINK-5147] - StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis
- [FLINK-5149] - ContinuousEventTimeTrigger doesn't fire at the end of the window
- [FLINK-5150] - WebUI metric-related resource leak
- [FLINK-5154] - Duplicate TypeSerializer when writing RocksDB Snapshot
- [FLINK-5158] - Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator
- [FLINK-5160] - SecurityContextTest#testCreateInsecureHadoopCtx fails on windows
- [FLINK-5162] - BlobRecoveryItCase#testBlobServerRecovery fails on Windows
- [FLINK-5164] - Hadoop-compat IOFormat tests fail on Windows
- [FLINK-5173] - Upgrade RocksDB dependency
- [FLINK-5179] - MetricRegistry life-cycle issues with HA
- [FLINK-5184] - Error result of compareSerialized in RowComparator class
- [FLINK-5193] - Recovering all jobs fails completely if a single recovery fails
- [FLINK-5197] - Late JobStatusChanged messages can interfere with running jobs
- [FLINK-5206] - Flakey PythonPlanBinderTest
- [FLINK-5209] - Fix TaskManager metrics
- [FLINK-5214] - Clean up checkpoint files when failing checkpoint operation on TM
- [FLINK-5216] - CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion
- [FLINK-5218] - Eagerly close checkpoint streams on cancellation
- [FLINK-5221] - Checkpointed workless in Window Operator
- [FLINK-5228] - LocalInputChannel re-trigger request and release deadlock
- [FLINK-5229] - Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails
- [FLINK-5247] - Fix incorrect check in allowedLateness() method. Make it a no-op for non-event time windows.
- [FLINK-5248] - SavepointITCase doesn't catch savepoint restore failure
- [FLINK-5261] - ScheduledDropwizardReporter does not properly clean up metrics
- [FLINK-5267] - TaskManager logs not scrollable
- [FLINK-5274] - LocalInputChannel throws NPE if partition reader is released
- [FLINK-5275] - InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled
- [FLINK-5285] - CancelCheckpointMarker flood when using at least once mode
- [FLINK-5289] - NPE when using value state on non-keyed stream
- [FLINK-5292] - Make the operators for 1.1->1.2 backwards compatible.
- [FLINK-5296] - Expose the old AlignedWindowOperators to the user through explicit commands.
- [FLINK-5298] - TaskManager crashes when TM log not existant
- [FLINK-5307] - Log configuration for every reporter
- [FLINK-5320] - Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)
- [FLINK-5321] - FlinkMiniCluster does not start Jobmanager MetricQueryService
- [FLINK-5323] - CheckpointNotifier should be removed from docs
- [FLINK-5326] - IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available
- [FLINK-5329] - Metric list is being cut off in the WebFrontend
- [FLINK-5330] - Harden KafkaConsumer08Test
- [FLINK-5332] - Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution
- [FLINK-5344] - docs don't build in dockerized jekyll; -p option is broken
- [FLINK-5345] - IOManager failed to properly clean up temp file directory
- [FLINK-5349] - Fix code sample for Twitter connector
- [FLINK-5350] - Don't overwrite existing Jaas config property
- [FLINK-5356] - librocksdbjni*.so is not deleted from /tmp directory
- [FLINK-5357] - WordCountTable fails
- [FLINK-5359] - Job Exceptions view doesn't scroll
- [FLINK-5361] - Flink shouldn't require Kerberos credentials
- [FLINK-5364] - Rework JAAS configuration to support user-supplied entries
- [FLINK-5365] - Mesos AppMaster/TaskManager should obey sigterm
- [FLINK-5369] - Rework jsr305 and logging dependencies
- [FLINK-5375] - Fix watermark documentation
- [FLINK-5379] - Flink CliFrontend does not return when not logged in with kerberos
- [FLINK-5380] - Number of outgoing records not reported in web interface
- [FLINK-5381] - Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)
- [FLINK-5382] - Taskmanager log download button causes 404
- [FLINK-5392] - flink-dist build failed when change scala version to 2.11
- [FLINK-5394] - the estimateRowCount method of DataSetCalc didn't work
- [FLINK-5397] - Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors
- [FLINK-5407] - Savepoint for iterative Task fails.
- [FLINK-5408] - RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders
- [FLINK-5417] - Fix the wrong config file name
- [FLINK-5418] - Estimated row size does not support nested types
- [FLINK-5419] - Taskmanager metrics not accessible via REST
- [FLINK-5427] - Typo in the event_timestamps_watermarks doc
- [FLINK-5432] - ContinuousFileMonitoringFunction is not monitoring nested files
- [FLINK-5434] - Remove unsupported project() transformation from Scala DataStream docs
- [FLINK-5443] - Create a path to migrate from the Rolling to the BucketingSink.
- [FLINK-5444] - Flink UI uses absolute URLs.
- [FLINK-5450] - WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window
- [FLINK-5464] - MetricQueryService throws NullPointerException on JobManager
- [FLINK-5467] - Stateless chained tasks set legacy operator state
- [FLINK-5468] - Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException
- [FLINK-5470] - Requesting non-existing log/stdout file from TM crashes the TM
- [FLINK-5473] - setMaxParallelism() higher than 1 is possible on non-parallel operators
- [FLINK-5482] - QueryableStateClient does not recover from a failed lookup due to a non-running job
- [FLINK-5483] - Link to "linking modules not contained in binary distribution" broken in all connector documentations
- [FLINK-5484] - Kryo serialization changed between 1.1 and 1.2
- [FLINK-5492] - BootstrapTools log wrong address of started ActorSystem
- [FLINK-5493] - FlinkDistributionOverlay does not properly display missing environment variables
- [FLINK-5495] - ZooKeeperMesosWorkerStore cannot be instantiated
- [FLINK-5496] - ClassCastException when using Mesos HA mode
- [FLINK-5504] - mesos-appmaster.sh logs to wrong directory
- [FLINK-5518] - HadoopInputFormat throws NPE when close() is called before open()
- [FLINK-5520] - Disable outer joins with non-equality predicates
- [FLINK-5530] - race condition in AbstractRocksDBState#getSerializedValue
- [FLINK-5531] - SSl code block formatting is broken
- [FLINK-5532] - Make the marker WindowAssigners for the fast aligned windows non-extendable.
- [FLINK-5549] - TypeExtractor fails with RuntimeException, but should use GenericTypeInfo
- [FLINK-5556] - BarrierBuffer resets bytes written on spiller roll over
- [FLINK-5560] - Header in checkpoint stats summary misaligned
- [FLINK-5561] - DataInputDeserializer#available returns one too few
- [FLINK-5562] - Driver fixes
- [FLINK-5578] - Each time application is submitted to yarn, application id increases by two
- [FLINK-5580] - Kerberos keytabs not working for YARN deployment mode
- [FLINK-5585] - NullPointer Exception in JobManager.updateAccumulators
- [FLINK-5602] - Migration with RocksDB job led to NPE for next checkpoint
- [FLINK-5612] - GlobPathFilter not-serializable exception
- [FLINK-5613] - QueryableState: requesting a non-existing key in RocksDBStateBackend is not consistent with the MemoryStateBackend and FsStateBackend
- [FLINK-5617] - Check new public APIs in 1.2 release
- [FLINK-5626] - Improve resource release in RocksDBKeyedStateBackend
- [FLINK-5637] - Default Flink configuration contains whitespace characters, causing parser WARNings
- [FLINK-5638] - Deadlock when closing two chained async I/O operators
- [FLINK-5643] - StateUtil.discardStateFuture fails when state future contains null value
- [FLINK-5660] - Not properly cleaning PendingCheckpoints up
- [FLINK-5663] - Checkpoint fails because of closed registry
- [FLINK-5666] - Blob files are not cleaned up from ZK storage directory
- [FLINK-5667] - Possible state data loss when task fails while checkpointing
- [FLINK-5670] - Local RocksDB directories not cleaned up
Improvement
- [FLINK-2090] - toString of CollectionInputFormat takes long time when the collection is huge
- [FLINK-2765] - Upgrade hbase version for hadoop-2 to 1.2 release
- [FLINK-3042] - Define a way to let types create their own TypeInformation
- [FLINK-3347] - TaskManager (or its ActorSystem) need to restart in case they notice quarantine
- [FLINK-3615] - Add support for non-native SQL types
- [FLINK-3670] - Kerberos: Improving long-running streaming jobs
- [FLINK-3677] - FileInputFormat: Allow to specify include/exclude file name patterns
- [FLINK-3702] - DataStream API PojoFieldAccessor doesn't support nested POJOs
- [FLINK-3719] - WebInterface: Moving the barrier between graph and stats
- [FLINK-3779] - Add support for queryable state
- [FLINK-3787] - Yarn client does not report unfulfillable container constraints
- [FLINK-3866] - StringArraySerializer claims type is immutable; shouldn't
- [FLINK-3869] - WindowedStream.apply with FoldFunction is too restrictive
- [FLINK-3899] - Document window processing with Reduce/FoldFunction + WindowFunction
- [FLINK-3904] - GlobalConfiguration doesn't ensure config has been loaded
- [FLINK-3921] - StringParser not specifying encoding to use
- [FLINK-4023] - Move Kafka consumer partition discovery from constructor to open()
- [FLINK-4037] - Introduce ArchivedExecutionGraph without any user classes
- [FLINK-4068] - Move constant computations out of code-generated `flatMap` functions.
- [FLINK-4104] - Restructure Gelly docs
- [FLINK-4129] - Remove the example HITSAlgorithm
- [FLINK-4161] - Quickstarts can exclude more flink-dist dependencies
- [FLINK-4179] - Update TPCHQuery3Table example
- [FLINK-4189] - Introduce symbols for internal use
- [FLINK-4190] - Generalise RollingSink to work with arbitrary buckets
- [FLINK-4203] - Improve Table API documentation
- [FLINK-4204] - Clean up gelly-examples
- [FLINK-4218] - Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting
- [FLINK-4222] - Allow Kinesis configuration to get credentials from AWS Metadata
- [FLINK-4241] - Cryptic expression parser exceptions
- [FLINK-4242] - Improve validation exception messages
- [FLINK-4245] - Metric naming improvements
- [FLINK-4247] - CsvTableSource.getDataSet() expects Java ExecutionEnvironment
- [FLINK-4248] - CsvTableSource does not support reading SqlTimeTypeInfo types
- [FLINK-4251] - Add possiblity for the RMQ Streaming Sink to customize the queue
- [FLINK-4253] - Rename "recovery.mode" config key to "high-availability"
- [FLINK-4260] - Allow SQL's LIKE ESCAPE
- [FLINK-4268] - Add a parsers for BigDecimal/BigInteger
- [FLINK-4281] - Wrap all Calcite Exceptions in Flink Exceptions
- [FLINK-4282] - Add Offset Parameter to WindowAssigners
- [FLINK-4299] - Show loss of job manager in Client
- [FLINK-4302] - Add JavaDocs to MetricConfig
- [FLINK-4306] - Fix Flink and Storm dependencies in flink-storm and flink-storm-examples
- [FLINK-4308] - Allow uploaded jar directory to be configurable
- [FLINK-4310] - Move BinaryCompatibility Check plugin to relevant projects
- [FLINK-4318] - Make master docs build target version-specific
- [FLINK-4322] - Unify CheckpointCoordinator and SavepointCoordinator
- [FLINK-4340] - Remove RocksDB Semi-Async Checkpoint Mode
- [FLINK-4366] - Enforce parallelism=1 For AllWindowedStream
- [FLINK-4369] - EvictingWindowOperator Must Actually Evict Elements
- [FLINK-4378] - Enable RollingSink to custom HDFS client configuration
- [FLINK-4396] - GraphiteReporter class not found at startup of jobmanager
- [FLINK-4410] - Report more information about operator checkpoints
- [FLINK-4431] - Introduce a "VisibleForTesting" annotation
- [FLINK-4435] - Replace Guava's VisibleForTesting annotation with Flink's annotation
- [FLINK-4439] - Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid
- [FLINK-4445] - Ignore unmatched state when restoring from savepoint
- [FLINK-4447] - Include NettyConfig options on Configurations page
- [FLINK-4457] - Make the ExecutionGraph independent of Akka
- [FLINK-4459] - Introduce SlotProvider for Scheduler
- [FLINK-4478] - Implement heartbeat logic
- [FLINK-4495] - Running multiple jobs on yarn (without yarn-session)
- [FLINK-4525] - Drop the "eager split pre-assignment" code paths
- [FLINK-4527] - Drop the "flinkAccumulators" from the Execution
- [FLINK-4539] - Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation"
- [FLINK-4541] - Support for SQL NOT IN operator
- [FLINK-4543] - Race Deadlock in SpilledSubpartitionViewTest
- [FLINK-4549] - Test and document implicitly supported SQL functions
- [FLINK-4550] - Clearly define SQL operator table
- [FLINK-4552] - Refactor WindowOperator/Trigger Tests
- [FLINK-4560] - enforcer java version as 1.7
- [FLINK-4579] - Add StateBackendFactory for RocksDB Backend
- [FLINK-4599] - Add 'explain()' also to StreamTableEnvironment
- [FLINK-4611] - Make "AUTO" credential provider as default for Kinesis Connector
- [FLINK-4623] - Create Physical Execution Plan of a DataStream
- [FLINK-4625] - Guard Flink processes against blocking shutdown hooks
- [FLINK-4638] - Fix exception message for MemorySegment
- [FLINK-4654] - clean up docs
- [FLINK-4662] - Bump Calcite version up to 1.9
- [FLINK-4668] - Fix positive random int generation
- [FLINK-4669] - scala api createLocalEnvironment() function add default Configuration parameter
- [FLINK-4684] - Remove obsolete classloader from CheckpointCoordinator
- [FLINK-4704] - Move Table API to org.apache.flink.table
- [FLINK-4715] - TaskManager should commit suicide after cancellation failure
- [FLINK-4720] - Implement an archived version of the execution graph
- [FLINK-4723] - Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer
- [FLINK-4728] - Replace reference equality with object equality
- [FLINK-4729] - Use optional VertexCentric CombineFunction
- [FLINK-4733] - Port WebFrontend to new metric system
- [FLINK-4734] - Remove use of Tuple setField for fixed position
- [FLINK-4736] - Don't duplicate fields in Ordering
- [FLINK-4737] - Add more compression algorithms to FileInputFormat
- [FLINK-4739] - Adding packaging details for the Elasticsearch connector
- [FLINK-4745] - Convert KafkaTableSource test to unit tests
- [FLINK-4751] - Extend Flink's futures to support combining two futures
- [FLINK-4752] - Improve session window documentation
- [FLINK-4762] - Use plural in time interval units
- [FLINK-4764] - Introduce config options
- [FLINK-4771] - Compression for AvroOutputFormat
- [FLINK-4772] - Store metrics in MetricStore as strings
- [FLINK-4773] - Introduce an OperatorIOMetricGroup
- [FLINK-4775] - Simplify access to MetricStore
- [FLINK-4776] - Move ExecutionGraph initialization into a dedicated class
- [FLINK-4780] - Ability to use UDP protocol in metrics-graphite
- [FLINK-4787] - Add REST API call for cancel-with-savepoints
- [FLINK-4792] - Update documentation - FlinkML/QuickStart Guide
- [FLINK-4825] - Implement a RexExecutor that uses Flink's code generation
- [FLINK-4832] - Count/Sum 0 elements
- [FLINK-4876] - Allow web interface to be bound to a specific ip/interface/inetHost
- [FLINK-4881] - Docker: Remove dependency on shared volumes
- [FLINK-4892] - Snapshot TimerService using Key-Grouped State
- [FLINK-4894] - Don't block on buffer request after broadcastEvent
- [FLINK-4906] - Use constants for the name of system-defined metrics
- [FLINK-4913] - Per-job Yarn clusters: include user jar in system class loader
- [FLINK-4917] - Deprecate "CheckpointedAsynchronously" interface
- [FLINK-4923] - Expose input/output buffers and bufferPool usage as a metric for a Task
- [FLINK-4924] - Simplify Operator Test Harness Constructors
- [FLINK-4925] - Integrate meters into IOMetricGroups
- [FLINK-4935] - Submit job with savepoint via REST API
- [FLINK-4936] - Operator names for Gelly inputs
- [FLINK-4939] - GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint
- [FLINK-4943] - flink-mesos/ConfigConstants: Typo: YYARN -> YARN
- [FLINK-4946] - Load jar files from subdirectories of lib
- [FLINK-4963] - Tabulate edge direction for directed VertexMetrics
- [FLINK-4970] - Parameterize vertex value for SSSP
- [FLINK-4972] - CoordinatorShutdownTest relies on race condition for success
- [FLINK-4975] - Add a limit for how much data may be buffered during checkpoint alignment
- [FLINK-4983] - Web UI: Add favicon
- [FLINK-4996] - Make CrossHint @Public
- [FLINK-5000] - Rename Methods in ManagedInitializationContext
- [FLINK-5003] - Provide Access to State Stores in Operator Snapshot Context
- [FLINK-5004] - Add task manager option to disable queryable state server
- [FLINK-5008] - Update quickstart documentation
- [FLINK-5010] - Decouple the death watch parameters from the Akka ask timeout
- [FLINK-5012] - Provide Timestamp in TimelyFlatMapFunction
- [FLINK-5020] - Make the GenericWriteAheadSink rescalable.
- [FLINK-5021] - Makes the ContinuousFileReaderOperator rescalable.
- [FLINK-5022] - Suppress RejectedExecutionException when the Executor is shut down
- [FLINK-5026] - Rename TimelyFlatMap to Process
- [FLINK-5034] - Don't Write StateDescriptor to RocksDB Snapshot
- [FLINK-5035] - Don't Write TypeSerializer to Heap State Snapshot
- [FLINK-5046] - Avoid redundant serialization when creating the TaskDeploymentDescriptor
- [FLINK-5054] - Make the BucketingSink rescalable.
- [FLINK-5096] - Make the RollingSink rescalable.
- [FLINK-5110] - Remove the AbstractAlignedProcessingTimeWindowOperator.
- [FLINK-5113] - Make all Testing Functions implement CheckpointedFunction Interface.
- [FLINK-5123] - Add description how to do proper shading to Flink docs.
- [FLINK-5124] - Support more temporal arithmetic
- [FLINK-5128] - Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set
- [FLINK-5145] - WebInterface to aggressive in pulling metrics
- [FLINK-5146] - Improved resource cleanup in RocksDB keyed state backend
- [FLINK-5155] - Deprecate ValueStateDescriptor constructors with default value
- [FLINK-5159] - Improve perfomance of inner joins with a single row input
- [FLINK-5163] - Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)
- [FLINK-5168] - Scaladoc annotation link use [[]] instead of {@link}
- [FLINK-5169] - Make consumption of input channels fair
- [FLINK-5181] - Add Tests in StateBackendTestBase that verify Default-Value Behaviour
- [FLINK-5185] - Decouple BatchTableSourceScan with TableSourceTable
- [FLINK-5186] - Move Row and RowTypeInfo into Flink core
- [FLINK-5192] - Provide better log config templates
- [FLINK-5194] - Log heartbeats on TRACE level
- [FLINK-5196] - Don't log InputChannelDescriptor
- [FLINK-5198] - Overwrite TaskState toString
- [FLINK-5199] - Improve logging of submitted job graph actions in HA case
- [FLINK-5201] - Promote loaded config properties to INFO
- [FLINK-5207] - Decrease HadoopFileSystem logging
- [FLINK-5211] - Include an example configuration for all reporters
- [FLINK-5213] - Missing @Override in Task
- [FLINK-5223] - Add documentation of UDTF in Table API & SQL
- [FLINK-5224] - Improve UDTF: emit rows directly instead of buffering them
- [FLINK-5226] - Eagerly project unused attributes
- [FLINK-5237] - Consolidate and harmonize Window Translation Tests
- [FLINK-5240] - Properly Close StateBackend in StreamTask when closing/canceling
- [FLINK-5249] - description of datastream rescaling doesn't match the figure
- [FLINK-5250] - Make AbstractUdfStreamOperator aware of WrappingFunction
- [FLINK-5251] - Decouple StreamTableSourceScan with TableSourceTable
- [FLINK-5255] - Improve single row check in DataSetSingleRowJoinRule
- [FLINK-5257] - Display optimized logical plan when explaining table
- [FLINK-5258] - reorganize the docs to improve navigation and reduce duplication
- [FLINK-5259] - wrong execution environment in retry delays example
- [FLINK-5266] - Eagerly project unused fields when selecting aggregation fields
- [FLINK-5278] - Improve Task and checkpoint logging
- [FLINK-5280] - Refactor TableSource
- [FLINK-5304] - Change method name from crossApply to join in Table API
- [FLINK-5306] - Display checkpointing configuration details in web UI "Configuration" tab
- [FLINK-5310] - Harden the RocksDB JNI library loading
- [FLINK-5311] - Write user documentation for BipartiteGraph
- [FLINK-5327] - Remove IOException from StateObject::getStateSize
- [FLINK-5335] - Allow ListCheckpointed user functions to return null
- [FLINK-5343] - Add more option to CsvTableSink
- [FLINK-5366] - Add end-to-end tests for Savepoint Backwards Compatibility
- [FLINK-5367] - restore updates lost when merging recent doc refactoring
- [FLINK-5368] - Let Kafka consumer show something when it fails to read one topic out of topic list
- [FLINK-5371] - Add documentation for async I/O
- [FLINK-5377] - Improve savepoint docs
- [FLINK-5395] - support locally build distribution by script create_release_files.sh
- [FLINK-5404] - Consolidate and update S3 documentation
- [FLINK-5412] - Enable RocksDB tests on Windows
- [FLINK-5421] - Explicit restore method in Snapshotable
- [FLINK-5424] - Improve Restart Strategy Logging
- [FLINK-5430] - Bring documentation up to speed for current feature set
- [FLINK-5438] - Typo in JobGraph generator Exception
- [FLINK-5442] - Add test to fix ordinals of serialized enum StateDescriptor.Type
- [FLINK-5446] - System metrics reference incomplete
- [FLINK-5447] - Sync documentation of built-in functions for Table API with SQL
- [FLINK-5448] - Fix typo in StateAssignmentOperation Exception
- [FLINK-5451] - Extend JMX metrics documentation section
- [FLINK-5452] - Make table unit tests pass under cluster mode
- [FLINK-5466] - Make production environment default in gulpfile
- [FLINK-5480] - User-provided hashes for operators
- [FLINK-5485] - Mark compiled web frontend files as binary when processed by git diff
- [FLINK-5507] - remove queryable list state sink
- [FLINK-5508] - Remove Mesos dynamic class loading
- [FLINK-5512] - RabbitMQ documentation should inform that exactly-once holds for RMQSource only when parallelism is 1
- [FLINK-5515] - fix unused kvState.getSerializedValue call in KvStateServerHandler
- [FLINK-5521] - remove unused KvStateRequestSerializer#serializeList
- [FLINK-5528] - tests: reduce the retry delay in QueryableStateITCase
- [FLINK-5557] - Fix link in library methods
- [FLINK-5559] - queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails
- [FLINK-5574] - Add checkpoint statistics docs
- [FLINK-5576] - extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes
- [FLINK-5609] - Add last update time to docs
- [FLINK-5610] - Rename Installation and Setup to Project Setup
- [FLINK-5615] - queryable state: execute the QueryableStateITCase for all three state back-ends
New Feature
- [FLINK-1984] - Integrate Flink with Apache Mesos
- [FLINK-3060] - Add possibility to integrate custom types into the TypeExtractor
- [FLINK-3097] - Add support for custom functions in Table API
- [FLINK-3239] - Support for Kerberos enabled Kafka <IP_ADDRESS>
- [FLINK-3674] - Add an interface for Time aware User Functions
- [FLINK-3755] - Introduce key groups for key-value state to support dynamic scaling
- [FLINK-3848] - Add ProjectableTableSource interface and translation rule
- [FLINK-3874] - Add a Kafka TableSink with JSON serialization
- [FLINK-3929] - Support for Kerberos Authentication with Keytab Credential
- [FLINK-3931] - Implement Transport Encryption (SSL/TLS)
- [FLINK-3932] - Implement State Backend Security
- [FLINK-3940] - Add support for ORDER BY OFFSET FETCH
- [FLINK-4180] - Create a batch SQL example
- [FLINK-4181] - Add a basic streaming Table API example
- [FLINK-4294] - Allow access of composite type fields
- [FLINK-4359] - Add INTERVAL type
- [FLINK-4379] - Add Rescalable Non-Partitioned State
- [FLINK-4391] - Provide support for asynchronous operations over streams
- [FLINK-4420] - Introduce star(*) to select all of the columns in the table
- [FLINK-4469] - Add support for user defined table function in Table API & SQL
- [FLINK-4546] - Remove STREAM keyword in Stream SQL
- [FLINK-4554] - Add support for array types
- [FLINK-4576] - Low Watermark Service in JobManager for Streaming Sources
- [FLINK-4639] - Make Calcite features more pluggable
- [FLINK-4643] - Average Clustering Coefficient
- [FLINK-4664] - Add translator to NullValue
- [FLINK-4717] - Naive version of atomic stop signal with savepoint
- [FLINK-4844] - Partitionable Raw Keyed/Operator State
- [FLINK-4861] - Package optional project artifacts
- [FLINK-4934] - Triadic Census
- [FLINK-4960] - Allow the AbstractStreamOperatorTestHarness to test scaling down
- [FLINK-4976] - Add a way to abort in flight checkpoints
- [FLINK-5265] - Introduce state handle replication mode for CheckpointCoordinator
Task
- [FLINK-4315] - Deprecate Hadoop dependent methods in flink-java
- [FLINK-4429] - Move Redis Sink from Flink to Bahir
- [FLINK-4446] - Move Flume Sink from Flink to Bahir
- [FLINK-4676] - Merge flink-batch-connectors and flink-streaming-connectors modules
- [FLINK-4778] - Update program example in /docs/setup/cli.md due to the change in FLINK-2021
- [FLINK-4891] - Remove flink-contrib/flink-operator-stats
- [FLINK-4895] - Drop support for Hadoop 1
Test
- [FLINK-4842] - Introduce test to enforce order of operator / udf lifecycles
- [FLINK-4843] - Introduce Test for FsCheckpointStateOutputStream::getPos
Wish
- [FLINK-4799] - Re-add build-target symlink to project root


Field is required
Minimum {{ employeeForm.controls.employee_id.errors.minlength.requiredLength }} characters
Maximum {{ employeeForm.controls.employee_id.errors.maxlength.requiredLength }} characters
Minimum {{ employeeForm.controls.first_name.errors.minlength.requiredLength }} characters
Maximum {{ employeeForm.controls.first_name.errors.maxlength.requiredLength }} characters
Mininum {{employeeForm.controls.last_name.errors.minlength.requiredLength }} characters
Maximum {{ employeeForm.controls.last_name.errors.maxlength.requiredLength }} characters
Email is required
Maximum {{ employeeForm.controls.mobile.errors.maxlength.requiredLength }} characters
Maximum {{ employeeForm.controls.phone.errors.maxlength.requiredLength }} characters
{{ message }}


Demo
The simple renderable demo on the following page consists of a
large source image, small image panning window, button to
perform the scale and invert operation, and the resultant
destination image. Pressing the
"Invert/Scale" button will shrink the source image and invert
its color components.
JAI
This demo utilizes the
methods to perform the scale and invert imaging operations.JAI.createRenderable()
JAI.createScaledRendering()
The "Invert" operation inverts the pixel values of an image. For source images with signed data types, the pixel values of the destination image are defined by the pseudocode:
dst[x][y][b] = -src[x][y][b]
For unsigned data types, the destination values are defined by:
dst[x][y][b] = MAX_VALUE - src[x][y][b]
where MAX_VALUE
is the maximum value supported by the
system of the data type of the source pixel.
Theory
The renderable API architecture integrates a model of
rendering independence with a parallel, device-dependent
(rendered) model. The rendering-independent portion of
the architecture is a superset of the traditional model
of device-dependent imaging.
The renderable layer provides image sources that can be reused multiple times in different contexts, such as screen display or printing. The renderable operators take rendering-independent parameters and can be chained together (operation chains) to form directed-acyclic-graphs(DAGS). Any class implementing the RenderableImage interface is a renderable source and must adapt to RenderContexts. Renderable images are referenced through user-defined coordinate systems.


{% include_relative _layouts/page_header.html %}
Specifying JavaScript.
{% include intro.html %} {% include proposals.html %}
GitHub
Attention
This site is in
beta
! We are looking for feedback. Please add issues to our
GitHub page
!!
×


%page args='const' /> <%inherit file='base.html' /> <%block name='title'>Welcome to tiroFinale%block>
<IP_ADDRESS>:${const.PROXY_PORT|h}
We will redirect you to the portal page after that. Skip this check


{% extends "base.html" %} {% block content %}
No plots disk stats recorded recently for {{farmer.hostname}} with Chia blockchain. Please ensure all paths containing plots have been configured. Also ensure the Chia worker is reporting into the controller on the Workers page.
{% endif %}


Workflows¶
Simple
Feature branch
Feature branch + merge requests
Gitflow (Master - Develop - Feature - Feature)
Forking workflow
Working pipeline¶
Single-time steps:
Create a central group and store the main repository there
Each developer forks the central repository
Clone the forked repository to the local computer
Create a branch to work on an issue
Everyday steps:
Merge changes from upstream to your local branch
Make changes to the code
Add, commit and push to the remote fork
Detailed workflow¶
In order to contribute to a third-party repository, you have to fork it, i.e. create your own copy in your GitHub account. Open web browser, log into your Aalto Version (or GitHub) account, go to the repository you want to contribute. Click on Fork
. A repository with the same name will be created in your own account page.
Now you have to clone it to your computer to edit the code and send it back to the online repository. Create a folder with na easy path, like D:\repository
. Open the terminal/shell and go to the desired folder:
Note
When you clone git will automatically create the folder with the repository name, so you do not need to manually create a specific folder to clone the code.
cd "D:\repository"
Copy the SSH path available on the forked repository web page and past it on the terminal.
From now on, let’s use as an example the username johnnybgood
, the repository name is tutorial-git
, and that the repository is on GitHub, but the same applies to Aalto Version.
git clone git@github.com:johnnybgood/tutorial-git.git
git remote -v # List all remote repositories linked to your local copy - origin is set by default
origin git@github.com:johnnybgood/tutorial-git.git (fetch)
origin git@github.com:johnnybgood/tutorial-git.git (push)
Now you can work on your local copy of tutorial-git. You will also want to be able to constantly get and make changes in the main project repository. You do that by adding a remote repository with the following command:
git remote add upstream git@github.com:biomaglab/tutorial-git.git
In order to contribute to other repositories, you can keep adding these remote connections. Using direct remote to others repositories can be useful for small teams developing large projects. For instance if johnnybgood
wants to contribute directly to marybcool
, he can add the following remote link:
git remote add marybcool_repo git@github.com:marybcool/tutorial-git.git
Note
upstream
is a conventional name used among git users, but is just a manually set name. For instance you can name it as main_project
. That is why we could name the marybcool
repo as marybcool_repo
.
You should always work on a branch other than the master. Let the branch master be just a mirror of the main repository code with the tested and stable code version. Thus, start by creating a branch named after the issue you are going to work, for instance new_colormap
.
git checkout -b new_colormap
After you created the new branch, jump between branches using the checkout
command followed by the branch name:
git checkout master
git checkout new_colormap
Now you can start the real work! After some programming you can add
changes to a staging area. You don’t have to upload every change, you can add many different files to the staging area and then upload them in separate snapshots of changes. Snapshots are the commits
, and is a good practive to never loose track of your code. So after editing a lot of different files and adding them to the staging area you can create separate commits for more focused changes in specific functions to the software or algorithm. After editing and before uploading changes, you have to identify the staged, unstaged and untracked files according to your local repo and the origin repo. Use the status
command.
Note
To ignore some undesired files such as .~m
or .pyc
or .exe
you can create a .gitignore
file at the root of source code and add in each line the type of file to be ignored by git like.
git status # Using the -s argument simplify the status description
git add . # Adds all changes to staging area
git commit # This will open the text editor to write the commit description
Note
Commit messages have to be short and informative. Avoid using abstract messages such as: Minor bugs fixed. Later you will have a hard time to know when you made specific changes.
Another way of using the add
and commit
commands is:
git add first-file.txt # Adds only changes to first-file to the staging area
git add first-file.txt second-file.txt # Adds changes to first-file and second-file to the staging area
git commit -m "FIX: Warning dialog was not showing fixed." # This commit with the specific message given and without opening the text editor
Inspecting your repository you can use:
git log --oneline -n 5 # View maximum of 5 last commits in one line description
git checkout 5a4763d5 # Move code to previous commit for read-only purpose. Does not affect the code.
git checkout 5a4763d5 <first-file.txt> # Checking out to a file directly is considered as a change to the code and will be available to be commited again. This affects the code.
The 5a4763d5
is the commit specific 8-digit identifier displayed after the log command or in the repository webpage. The checkout
command allows you to travel along the code history.
It is possible to revert a specific commit. Git will apply the changes of removing a single past commit and will create a new commit with the new changes. It is a safe operation beacuse does not chenge the project history. While git reset will delete previous commits and go back to the specified commit, so it is a dangerous method beacuse modify project history. Git reset can also be used to clean the staging area from undersider commits.
Warning
Use revert
and reset
commands carefully, because you can create a big mess in the code for you and all other collaborators.
git revert 5a4763d5
git reset 5a4763d5
You may want to upload your created local repository to the remote repository. Use the following command to push and track it:
git push -u origin new_colormap
In a daily routine you will want to make changes to your code and have them available in the remote repository. Think that you will be working in the same feature on your laptop and your workstation at the University. To do so, it’s best to keep the remote repository always updated. After you worked on your laptop and commited your changes, you can push them to the remote repository by:
git push origin new_colormap
On the other day, you go to the University and will work on the workstation. If your branch is not on your workstation yet, add it by:
git pull # this will fetch all remote branches
git checkout new_colormap
Or:
git checkout -t origin/new_colormap
If the branch is already on your computer, download the changes you made the day before using the pull
command.
git pull origin new_colormap
Now, consider that other collaborators made changes to the main repository that were already incorporated
git fetch origin # Download remote commits and branches
git log --oneline master.. origin/master # See what commits were added
git checkout master # Move to master
git log origin/master # See what is on origin/master
git merge origin/master # Synchronize origin/master into local master
To make things easier the pull command wrapps the fetch and merge into one command.
git pull origin # It is the same as "git fetch origin" + "git merge origin/master"
Note
Further instructions will soon be added.


About
I am a 20 year old CSE Student interested in Java,Flutter.i like to work on open source projects and in cyber security,i have founded security vulnerabilities in many websites and helped them to fix that.
i am creating content on my instagram page @Coding_boy_(95K+ developers community)
Looking for an opportunity to work in a challenging position combining my skills in Software Engineering, which provides professional development, interesting experiences and personal growth.
Projects
Skills
Languages and Technologies
Education
Bhuj, India
Diploma In Computer Engineering (2016 - 2019)
CGPA: 9.40/10.00
- Data Structures and Algorithms
- Database Management Systems
- Operating Systems
- Computer Network
- C,Java,Php
Relevant Courseworks:


What It Means to “See” Behaviors of Interest¶
Remember, the video camera is a filter. If the behaviors are not on camera, you cannot see them and you cannot code them; they might as well have never happened. Datavyu allows you to view your videos at various speeds. Exploit this feature to determine whether the behaviors of interest are adequately visible for coding.
On Camera¶
Camera views make all the difference. With well-designed camera views, the behaviors of interest are visible and large on the video frame. It can be advantageous to collect data from multiple camera views: different behaviors may be visible from different angles, and it is often helpful to have multiple perspectives on a single behavior. Datavyu can synchronize views from different video files or you can use commercial software to merge and synchronize your camera views onto a single video frame. Often, the critical behavior of interest is obscured on one camera view; multiple camera views ensures that you will always be able to see the behavior.
Viewing Speed¶
Visibility varies depending on the viewing speed. For many behaviors, you will want to view the videos at speeds slower than real time. Datavyu provides easy, fingertip control over the viewing speed with the shuttle keys—allowing you to slow down, speed up, or pause the video with a tap of a finger. You can also view the videos frame by frame using fingertip control over the jog keys.
Rules of Thumb¶
Use HD video for a crisper, higher resolution image. But, be aware of data storage requirements. Most people don’t need the highest setting on their camera, which results in huge, unmanageable files. Large files also require more powerful computers for playback. The “lowest” HD setting is a lot easier to store and for most purposes looks great. Thus, consider the trade-off between higher resolution videos and storage/processing requirements. Your camera lenses and apertures will also affect whether the image is blurry, distorted, dark, or over-exposed.
In general, it is easier to code things you can see rather than things that you hear.
Use visual cues, not sound cues to demarcate sections of video. You can only hear sound while playing the video in real time and it is difficult to determine when a sound begins or ends with frame precision. Use visual contrast, not sound, to demarcate important sections of your recording session (e.g., new conditions, new trials). Abrupt changes in contrast are easier to see than subtle visual changes, especially at faster than real-time speeds (and you are likely to want to fast forward to different sections of your video). Flipping the room lights on and off provides an easily implemented and visible demarcation of sections of the session. Holding a bright card in front of a camera (with condition name or trial number) provides another easily implemented and visible demarcation of sections of the session.
Use multiple camera views to capture both small body parts/small movements and the whole body/scene. Small body parts, small movements, facial expressions, and eye movements are difficult to see when they are small in the video frame.
Part of planning your recording arrangement involves thinking about your recording context. For example, white skin is difficult to see against a light background and dark skin is difficult to see against a dark background. So, create more visual contrast by making your background a bright or saturated color or dressing the child in a bright or saturated color (we use bright blue carpets and mats because infants’ hands and feet are clearly visible against them).
Video Example¶
This video displays how easy it is to record videos that miss the behaviors of interest. The experimenter was interested in understanding how parents teach children to open containers. You can see by the video example that the single camera view is completely blocked by the parent.
Revise or add more camera views until you can thoroughly see your behaviors of interest.


| 028:040 Khan | : |
So We seized him and his hosts, and We threw them all into the sea (and drowned them). So behold (O Muhammad SAW) what was the end of the Zalimun [wrong-doers, polytheists and those who disbelieved in the Oneness of their Lord (Allah), or rejected the advice of His Messenger Musa (Moses)]. |
| 028:040 Maulana | : |
So We caught hold of him and his hosts, then We cast them into the sea, and see what was the end of the iniquitous. |
| 028:040 Pickthal | : |
Therefor We seized him and his hosts, and abandoned them unto the sea. Behold the nature of the consequence for evil-doers! |
| 028:040 Rashad | : |
Consequently, we punished him and his troops, by throwing them into the sea. Note the consequences for the transgressors. |
| 028:040 Sarwar | : |
We sized him and his army and threw them into the sea. See how terrible was the end of the unjust people! |
| 028:040 Shakir | : |
So We caught hold of him and his hosts, then We cast them into the sea, and see how was the end of the unjust. |
| 028:040 Sherali | : |
So WE seized him and his hosts and cast them into the sea. See, then, how evil was the end of the wrongdoers ! |
| 028:040 Yusufali | : |
So We seized him and his hosts, and We flung them into the sea: Now behold what was the end of those who did wrong! |
Concepts/Themes Covered:
This tool uses eight English parallel translations for the Holy Quran imported from Mr. Clay Smith. You can also visit Qurany Concepts for browsing the Quran themes or topics. If you want to search the Holy Quran for keywords, please visit Qurany Keywords.


Namespace for resource-related functionality. More...
Classes | |
| struct | CentralOwner |
| Centralized ownership policy. More... | |
| struct | RefCounted |
| Reference-counted ownership policy. More... | |
Enumerations | |
| enum | KnownIdStrategy { AssumeNew, Reuse, Reload } |
| Strategy to deal with already known resource IDs. More... | |
Functions | |
| template<class R > | |
| ResourceLoader< R > | fromFile (const std::string &filename) |
| Load the resource from a file on hard disk. | |
| template<class R , typename T > | |
| ResourceLoader< R > | fromFile (const std::string &filename, T arg1) |
| Load the resource from a file on hard disk. | |
| template<class R , typename T , typename U > | |
| ResourceLoader< R > | fromMemory (T arg1, U arg2) |
| Load the resource from a file in memory. | |
| template<class R , typename T , typename U , typename V > | |
| ResourceLoader< R > | fromMemory (T arg1, U arg2, V arg3) |
| Load the resource from a file in memory. | |
| template<class R > | |
| ResourceLoader< R > | fromStream (sf::InputStream &stream) |
| Load the resource from an input stream. | |
| template<class R > | |
| ResourceLoader< R > | fromStream (sf::InputStream &vertexShaderStream, sf::InputStream &fragmentShaderStream) |
| Load the resource (usually sf::Shader) from two streams. | |
| template<class R , typename T > | |
| ResourceLoader< R > | fromStream (sf::InputStream &stream, T arg1) |
| Load the resource from a stream with additional information. | |
| template<class R > | |
| ResourceLoader< R > | fromSamples (const sf::Int16 *samples, std::size_t sampleCount, unsigned int channelCount, unsigned int sampleRate) |
| Load sf::SoundBuffer from array of audio samples in memory. | |
| template<class R > | |
| ResourceLoader< R > | fromPixels (unsigned int width, unsigned int height, const sf::Uint8 *pixels) |
| Load resource (usually sf::Image) from array of pixels. | |
| template<class R > | |
| ResourceLoader< R > | fromColor (unsigned int width, unsigned int height, const sf::Color &color) |
| Load resource (usually sf::Image) from size and fill color. | |
| template<class R > | |
| ResourceLoader< R > | fromImage (const sf::Image &image, const sf::IntRect area=sf::IntRect()) |
| Load the resource (usually sf::Texture) from a sf::Image. |
Namespace for resource-related functionality.
Strategy to deal with already known resource IDs.
Determines what happens if the user calls ResourceHolder::acquire() with an ID that is already associated with a different resource.
| AssumeNew |
Loads a new resource if the ID is unknown. Otherwise, a ResourceAccessException is thrown. |
| Reuse |
Loads a new resource if the ID is unknown. Otherwise, the resource associated with the ID is reused. |
| Reload |
Always loads a new resource. If the ID is already known, the corresponding resource is released. |
| ResourceLoader<R> thor::Resources::fromColor | ( | unsigned int | width, |
| unsigned int | height, | ||
| const sf::Color & | color | ||
| ) |
Load resource (usually sf::Image) from size and fill color.
| width,height | The size of the image. |
| color | The color used to fill the image. |
| ResourceLoader<R> thor::Resources::fromFile | ( | const std::string & | filename | ) |
Load the resource from a file on hard disk.
| filename | The name of the file from which you want to load the resource. |
| ResourceLoader<R> thor::Resources::fromFile | ( | const std::string & | filename, |
| T | arg1 | ||
| ) |
Load the resource from a file on hard disk.
| filename | The name of the file from which you want to load the resource. |
| arg1 | An additional argument (for example sf::IntRect at sf::Texture or std::string / sf::Shader::Type at sf::Shader). |
| ResourceLoader<R> thor::Resources::fromImage | ( | const sf::Image & | image, |
| const sf::IntRect | area = sf::IntRect() |
||
| ) |
Load the resource (usually sf::Texture) from a sf::Image.
| image | Image to load into the texture. |
| area | Area of the image to load. |
| ResourceLoader<R> thor::Resources::fromMemory | ( | T | arg1, |
| U | arg2 | ||
| ) |
Load the resource from a file in memory.
| arg1 | Usually const void* for a pointer in memory; alternatively std::string for shader. |
| arg2 | Usually std::size_t for the data length in bytes; alternatively std::string or sf::Shader::Type for shader. |
| ResourceLoader<R> thor::Resources::fromMemory | ( | T | arg1, |
| U | arg2, | ||
| V | arg3 | ||
| ) |
Load the resource from a file in memory.
| arg1 | Usually const void* for a pointer in memory; alternatively std::string for shader. |
| arg2 | Usually std::size_t for the data length in bytes; alternatively std::string or sf::Shader::Type for shader. |
| arg3 | An additional argument (for example sf::IntRect at sf::Texture). |
| ResourceLoader<R> thor::Resources::fromPixels | ( | unsigned int | width, |
| unsigned int | height, | ||
| const sf::Uint8 * | pixels | ||
| ) |
Load resource (usually sf::Image) from array of pixels.
| width,height | The size of the image. |
| pixels | Pointer to the pixels in memory. |
| ResourceLoader<R> thor::Resources::fromSamples | ( | const sf::Int16 * | samples, |
| std::size_t | sampleCount, | ||
| unsigned int | channelCount, | ||
| unsigned int | sampleRate | ||
| ) |
Load sf::SoundBuffer from array of audio samples in memory.
| samples | Pointer to the samples array. |
| sampleCount | Number of samples in the array. |
| channelCount | Number of channels (1 = mono, 2 = stereo, ...). |
| sampleRate | Sample rate (number of samples to play per second). |
| ResourceLoader<R> thor::Resources::fromStream | ( | sf::InputStream & | stream | ) |
Load the resource from an input stream.
| stream | Source stream to read from. |
| ResourceLoader<R> thor::Resources::fromStream | ( | sf::InputStream & | vertexShaderStream, |
| sf::InputStream & | fragmentShaderStream | ||
| ) |
Load the resource (usually sf::Shader) from two streams.
| vertexShaderStream | Source stream to read the vertex shader from. |
| fragmentShaderStream | Source stream to read the fragment shader from. |
| ResourceLoader<R> thor::Resources::fromStream | ( | sf::InputStream & | stream, |
| T | arg1 | ||
| ) |
Load the resource from a stream with additional information.
| stream | Source stream to read from. |
| arg1 | An additional argument (for example sf::IntRect at sf::Texture or std::string / sf::Shader::Type at sf::Shader). |


{{$index+1}} |
{{link.title}}{{link.description}} |
{{keyword}} |
|
No recipes found matching that search term.
|
Either use Git to download this repo so you can work on it:
# Clone the repo git clone git@github.com:hash-bang/ngCookbook.git # Install all bower components bower install
Or fork this repo and work on it yourself.
All ngCookbook examples must conform to the following standards:


To create an annotation, select text and click the button.
To add a note to the page you are viewing, click the button.
To create a highlight, select text and click the button.
To reply to an annotation, click the Reply link.
To share an annotated page, click the button at the top.
To create a private group, select Public, open the dropdown, click + New group.