Edward J Beckett edwardbeckett

Introduction to scalaz-stream

Every application ever written can be viewed as some sort of transformation on data. Data can come from different sources, such as a network or a file or user input or the Large Hadron Collider. It can come from many sources all at once to be merged and aggregated in interesting ways, and it can be produced into many different output sinks, such as a network or files or graphical user interfaces. You might produce your output all at once, as a big data dump at the end of the world (right before your program shuts down), or you might produce it more incrementally. Every application fits into this model.

The scalaz-stream project is an attempt to make it easy to construct, test and scale programs that fit within this model (which is to say, everything). It does this by providing an abstraction around a "stream" of data, which is really just this notion of some number of data being sequentially pulled out of some unspecified data source. On top of this abstraction, sca

#gridx, gridy#

Specify the row and column at the upper left of the component. The leftmost column has address gridx=0 and the top row has address gridy=0. Use GridBagConstraints.RELATIVE (the default value) to specify that the component be placed just to the right of (for gridx) or just below (for gridy) the component that was added to the container just before this component was added. We recommend specifying the gridx and gridy values for each component rather than just using GridBagConstraints.RELATIVE; this tends to result in more predictable layouts.

#gridwidth, gridheight#

Specify the number of columns (for gridwidth) or rows (for gridheight) in the component's display area. These constraints specify the number of cells the component uses, not the number of pixels it uses. The default value is 1. Use GridBagConstraints.REMAINDER to specify that the component be the last one in its row (for gridwidth) or column (for gridheight). Use GridBagConstraints.RELATIVE to specify that the component be t

	package net.warmwaffles.utils.concurrent;

	import java.util.concurrent.BlockingQueue;
	import java.util.concurrent.ThreadPoolExecutor;
	import java.util.concurrent.TimeUnit;
	import java.util.concurrent.locks.Condition;
	import java.util.concurrent.locks.ReentrantLock;

	/**
	* A light wrapper around the {@link ThreadPoolExecutor}. It allows for you to pause execution and

	import com.sun.javafx.application.PlatformImpl;
	import java.awt.BorderLayout;
	import java.awt.Dimension;
	import java.awt.event.ActionEvent;
	import java.awt.event.ActionListener;
	import javafx.application.Platform;
	import javafx.collections.ObservableList;
	import javafx.embed.swing.JFXPanel;
	import javafx.scene.Group;
	import javafx.scene.Node;

	#!/usr/bin/env bash

	##############################################################################
	##
	## Gradle start up script for UN*X
	##
	##############################################################################

	# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
	DEFAULT_JVM_OPTS=""

	-server
	-Xms2g
	-Xmx2g
	-Xss16m
	-XX:+UseConcMarkSweepGC
	-XX:+CMSParallelRemarkEnabled
	-XX:ConcGCThreads=4
	-XX:ReservedCodeCacheSize=128m
	-XX:+AlwaysPreTouch
	-XX:+TieredCompilation

	public class StringTokens {

	public static void main( String[] args ) {
	System.out.print( "\nThis sentence inserts one new line before it starts and two after it ends\n\n" );
	System.out.print( "This is here to prove the later.\n" );
	}

	}

	import java.sql.*;

	public class DBConnection {

	public DBConnection(String username, String password, String db) {
	Connection conn;
	try {
	String url = "jdbc:mysql://localhost:3306/" + db;
	Class.forName( "com.mysql.jdbc.Driver" ).newInstance();
	conn = DriverManager.getConnection( url, username, password );

	<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
	http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.something</groupId>
	<artifactId>your-artifact</artifactId>
	<version>1.0-SNAPSHOT</version>
	<packaging>jar</packaging>

	EAR
	- META-INF/application.xml
	- some.jar
	- some classes, no beans.xml here
	- commonlib.jar
	- common lib resource classes
	- META-INF/beans.xml
	- data.jar
	- api implementation for data classes
	- META-INF/beans.xml