Luke Hoersten is sharing code with you

Bitbucket is a code hosting site. Unlimited public and private repositories. Free for small teams.

Don't show this again

LukeHoersten / Java Disco Worker http://discoproject.org/

Disco (http://discoproject.org) Java worker implementation with a focus on keeping things simple and type-safe. The goal is to allow map-reduce jobs to be submitted and run from a single Java jar.

Clone this repository (size: 154.0 KB): HTTPS / SSH
hg clone https://bitbucket.org/LukeHoersten/java-disco-worker
hg clone ssh://hg@bitbucket.org/LukeHoersten/java-disco-worker

Searching for commits

Mercurial supports a functional language for selecting a set of revisions.

The language supports a number of predicates which are joined by infix operators. Parenthesis can be used for grouping.

Identifiers such as branch names must be quoted with single or double quotes if they contain characters outside of [._a-zA-Z0-9\x80-\xff] or if they match one of the predefined predicates.

Prefix operators

not x
Changesets not in x. Short form is ! x.

Infix operators

x::y

A DAG range, meaning all changesets that are descendants of x and ancestors of y, including x and y themselves. If the first endpoint is left out, this is equivalent to ancestors(y), if the second is left out it is equivalent to descendants(x).

An alternative syntax is x..y.

x:y
All changesets with revision numbers between x and y, both inclusive. Either endpoint can be left out, they default to 0 and tip.
x and y
The intersection of changesets in x and y. Short form is x & y.
x or y
The union of changesets in x and y. There are two alternative short forms: x | y and x + y.
x - y
Changesets in x but not in y.

Predicates

all()
All changesets, the same as 0:tip.
ancestor(single, single)
Greatest common ancestor of the two changesets.
ancestors(set)
Changesets that are ancestors of a changeset in set.
author(string)
Alias for user(string).
bookmark([name])
The named bookmark or all bookmarks.
branch(set)
All changesets belonging to the branches of changesets in set.
children(set)
Child changesets of changesets in set.
closed()
Changeset is closed.
date(interval)
Changesets within the interval, see hg help dates.
descendants(set)
Changesets which are descendants of changesets in set.
file(pattern)
Changesets affecting files matched by pattern.
follow()
An alias for ::. (ancestors of the working copy's first parent).
grep(regex)
Like keyword(string) but accepts a regex. Use grep(r'...') to ensure special escape characters are handled correctly.
head()
Changeset is a named branch head.
heads(set)
Members of set with no children in set.
id(string)
Revision non-ambiguously specified by the given hex string prefix.
keyword(string)
Search commit message, user name, and names of changed files for string.
limit(set, n)
First n members of set.
max(set)
Changeset with highest revision number in set.
merge()
Changeset is a merge changeset.
min(set)
Changeset with lowest revision number in set.
p1([set])
First parent of changesets in set, or the working directory.
p2([set])
Second parent of changesets in set, or the working directory.
parents([set])
The set of all parents for all changesets in set, or the working directory.
present(set)
An empty set, if any revision in set isn't found; otherwise, all revisions in set.
rev(number)
Revision with the given numeric identifier.
roots(set)
Changesets with no parent changeset in set.
tag(name)
The specified tag by name, or all tagged revisions if no name is given.
user(string)
User name is string.

Commits 1–26 of 26

Author Revision Comments Message Labels Date
Luke Hoersten d0c6e30341f3 Added jobName to map and reduce function callbacks.
Luke Hoersten f3a1b7f2d740 Added more unit tests.
Luke Hoersten 9d1c2b424ad5 Backed out changeset: d1b43aab2387
Luke Hoersten 5a4310982ea2 Forgot to move unit tests to the discoproject.org namespace.
Luke Hoersten 01be435d1327 Removed json.jar from build script and added some raw util unit tests.
Luke Hoersten ac9aa1ce3300 Removed crufty class reference.
Luke Hoersten af0b82fe3c44 Changed behavior of DiscoUtils.encodeRaw to prepend raw URL scheme and added a String[] based version.
Luke Hoersten 9d627fb3db7e Removed JSON dep from README.
Luke Hoersten a395bc448f83 Merge
Aaron Graddy f51a3f98c88e Removing json jar dependency.
Luke Hoersten d1b43aab2387 Cleaned up the nasty Disco stdio output stream.
Luke Hoersten 2d05141a26c1 Moved java disco worker to org.discoproject package.
Luke Hoersten 42ea470b2772 Added ability to pipe stdout and stderr through the disco worker protocol.
Luke Hoersten 5a69488d0be1 Fixed a bug with passing VM args to the worker main.
Luke Hoersten 8c3538164c2d Added git and mercurial mirrors.
Luke Hoersten 139babefd542 Added some more readme stuff.
Luke Hoersten aa4b1d5a3025 Added some debug features.
Luke Hoersten 90a55b92895a Added support for task working dir.
Luke Hoersten 3ce95ef0d13f Refactored worker start script a bit. Added support for extra jars on the worker classpath.
Luke Hoersten db69d8bddf20 Fixed bugs, adding unit tests, and changed byte arrays and streams to byte buffers and channels.
Luke Hoersten ad5dc682d11b Minor refactors
Luke Hoersten 85f47f510728 Added ant script to build.
Luke Hoersten 667786b4052f Added dependencies section to README.
Luke Hoersten 048dd43a575b Beefed up README
Luke Hoersten 9ec888dc5e82 Added readme
Luke Hoersten 7a8cc8ace8c9 Initial Java Disco Worker