sample.java

StatusListener listener = new StatusListener() {
  @Override
	public void onStatus(Status status) {
		// do stuff with tweet
	}

	@Override
	public void onDeletionNotice(StatusDeletionNotice sdn) { }
	
	@Override
	public void onTrackLimitationNotice(int i) { }
	
	@Override
	public void onScrubGeo(long l, long l1) { }
	
	@Override
	public void onException(Exception e) { }
};
		
TwitterStreamFactory factory = new TwitterStreamFactory(new ConfigurationBuilder().setUser(username).setPassword(pwd).build());
TwiterStream twitterStream = factory.getInstance();
twitterStream.addListener(listener);
twitterStream.sample();