code: protected void setConnectionInformation() throws IOException
      {
          super.setConnectionInformation();
          if (System.getenv(PIG_ALLOW_DELETES) != null)
              allow_deletes = Boolean.parseBoolean(System.getenv(PIG_ALLOW_DELETES));
      }
docs: set hadoop cassandra connection settings